@ -38,7 +38,7 @@ def update_latest_version():
|
|||||||
self = CurrentTask.get_task()
|
self = CurrentTask.get_task()
|
||||||
if CONFIG.get_bool("disable_update_check"):
|
if CONFIG.get_bool("disable_update_check"):
|
||||||
cache.set(VERSION_CACHE_KEY, VERSION_NULL, VERSION_CACHE_TIMEOUT)
|
cache.set(VERSION_CACHE_KEY, VERSION_NULL, VERSION_CACHE_TIMEOUT)
|
||||||
self.warning("Version check disabled.")
|
self.info("Version check disabled.")
|
||||||
return
|
return
|
||||||
try:
|
try:
|
||||||
response = get_http_session().get(
|
response = get_http_session().get(
|
||||||
|
@ -361,7 +361,8 @@ DRAMATIQ = {
|
|||||||
"dramatiq.middleware.time_limit.TimeLimit",
|
"dramatiq.middleware.time_limit.TimeLimit",
|
||||||
{
|
{
|
||||||
# 5 minutes task timeout by default for all tasks
|
# 5 minutes task timeout by default for all tasks
|
||||||
"time_limit": 600 * 1000,
|
"time_limit": 600
|
||||||
|
* 1000,
|
||||||
},
|
},
|
||||||
),
|
),
|
||||||
("dramatiq.middleware.shutdown.ShutdownNotifications", {}),
|
("dramatiq.middleware.shutdown.ShutdownNotifications", {}),
|
||||||
|
@ -47,7 +47,8 @@ def ldap_connectivity_check(pk: str | None = None):
|
|||||||
# We take the configured hours timeout time by 3.5 as we run user and
|
# We take the configured hours timeout time by 3.5 as we run user and
|
||||||
# group in parallel and then membership, then deletions, so 3x is to cover the serial tasks,
|
# group in parallel and then membership, then deletions, so 3x is to cover the serial tasks,
|
||||||
# and 0.5x on top of that to give some more leeway
|
# and 0.5x on top of that to give some more leeway
|
||||||
time_limit=(60 * 60 * CONFIG.get_int("ldap.task_timeout_hours") * 1000) * 3.5,
|
time_limit=(60 * 60 * CONFIG.get_int("ldap.task_timeout_hours") * 1000)
|
||||||
|
* 3.5,
|
||||||
)
|
)
|
||||||
def ldap_sync(source_pk: str):
|
def ldap_sync(source_pk: str):
|
||||||
"""Sync a single source"""
|
"""Sync a single source"""
|
||||||
|
Reference in New Issue
Block a user