diff --git a/src/app/services/updaters/fl_updater.py b/src/app/services/updaters/fl_updater.py index 24ab899..25110fe 100644 --- a/src/app/services/updaters/fl_updater.py +++ b/src/app/services/updaters/fl_updater.py @@ -762,7 +762,7 @@ class FlUpdater: return True -async def run_fl_update(ctx) -> bool: +async def run_fl_update(ctx: dict, *args, **kwargs) -> bool: return await FlUpdater()._import(ctx) diff --git a/src/core/setup_arq.py b/src/core/setup_arq.py index 4e59d10..bd286db 100644 --- a/src/core/setup_arq.py +++ b/src/core/setup_arq.py @@ -1,3 +1,5 @@ +from arq.cron import cron + from app.services.updaters.fl_updater import run_fl_update, run_fl_update2 from core.arq_pool import get_redis_settings, get_arq_pool @@ -12,3 +14,6 @@ class WorkerSettings: redis_settings = get_redis_settings() max_jobs = 1 job_timeout = 30 * 60 + cron_jobs = [ + cron(run_fl_update, hour={5}, minute=0) + ]