refactor: enhance init_scheduler to include xpack job execution
parent
42d91e232b
commit
da73582093
|
|
@ -22,6 +22,14 @@ def init_scheduler():
|
||||||
|
|
||||||
job.run()
|
job.run()
|
||||||
|
|
||||||
|
try:
|
||||||
|
from xpack import job as xpack_job
|
||||||
|
|
||||||
|
xpack_job.run()
|
||||||
|
except ImportError:
|
||||||
|
pass
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
@worker_ready.connect
|
@worker_ready.connect
|
||||||
def on_app_ready(sender=None, headers=None, **kwargs):
|
def on_app_ready(sender=None, headers=None, **kwargs):
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue