we need to let our configuration actions finish (so that tasks are al…

…l registered) before we can build the celery app
OpenNTI · Feb 4, 2020 · ff754f2 · ff754f2
1 parent d863616
commit ff754f2
Showing 1 changed file with 6 additions and 4 deletions.
diff --git a/src/nti/app/environments/tasks/__init__.py b/src/nti/app/environments/tasks/__init__.py
@@ -16,9 +16,11 @@ def includeme(config):
     The celery application is made available as utility
     registered as ICeleryApp
     """
-    app = configure_celery(settings=component.getUtility(ISettings))
+    def _build_celery():
+        app = configure_celery(settings=component.getUtility(ISettings))
 
-    interface.alsoProvides(app, ICeleryApp)
-    getGlobalSiteManager().registerUtility(app, ICeleryApp)
+        interface.alsoProvides(app, ICeleryApp)
+        getGlobalSiteManager().registerUtility(app, ICeleryApp)
+        app.finalize()
 
-    config.action(("celery", "finalize"), app.finalize)
+    config.action(("celery", "setup"), _build_celery)