refactor: enhance init_scheduler to include xpack job execution

2025-12-26 01:33:05 +00:00 · 2025-11-07 21:12:29 +08:00 · 2025-11-07 21:12:29 +08:00 · da73582093
parent 42d91e232b
commit da73582093
1 changed files with 8 additions and 0 deletions
--- 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):