diff --git a/swh/scheduler/celery_backend/listener.py b/swh/scheduler/celery_backend/listener.py --- a/swh/scheduler/celery_backend/listener.py +++ b/swh/scheduler/celery_backend/listener.py @@ -172,6 +172,7 @@ recv.capture(limit=None, timeout=None, wakeup=True) + if __name__ == '__main__': main_backend = SchedulerBackend() event_monitor(main_app, main_backend) diff --git a/swh/scheduler/celery_backend/runner.py b/swh/scheduler/celery_backend/runner.py --- a/swh/scheduler/celery_backend/runner.py +++ b/swh/scheduler/celery_backend/runner.py @@ -49,6 +49,7 @@ backend.commit() + if __name__ == '__main__': for module in main_app.conf.CELERY_IMPORTS: __import__(module)