Skip to content

Commit 706f387

Browse files
committed
refactor: enhance init_scheduler to include xpack job execution
1 parent 45bdaf5 commit 706f387

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

apps/ops/celery/signal_handler.py

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -22,6 +22,14 @@ def init_scheduler():
2222

2323
job.run()
2424

25+
try:
26+
from xpack import job as xpack_job
27+
28+
xpack_job.run()
29+
except ImportError:
30+
pass
31+
32+
2533

2634
@worker_ready.connect
2735
def on_app_ready(sender=None, headers=None, **kwargs):

0 commit comments

Comments
 (0)