From da73582093f06bad0cd4e530746d4bff3a6f80f8 Mon Sep 17 00:00:00 2001 From: CaptainB Date: Fri, 7 Nov 2025 21:12:29 +0800 Subject: [PATCH] refactor: enhance init_scheduler to include xpack job execution --- apps/ops/celery/signal_handler.py | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/apps/ops/celery/signal_handler.py b/apps/ops/celery/signal_handler.py index 132ca350d..d592803fc 100644 --- a/apps/ops/celery/signal_handler.py +++ b/apps/ops/celery/signal_handler.py @@ -22,6 +22,14 @@ def init_scheduler(): job.run() + try: + from xpack import job as xpack_job + + xpack_job.run() + except ImportError: + pass + + @worker_ready.connect def on_app_ready(sender=None, headers=None, **kwargs):