From ff754f292db1514db7a387353b6e3280393ddc0b Mon Sep 17 00:00:00 2001 From: cutz Date: Tue, 4 Feb 2020 11:40:02 -0600 Subject: [PATCH] we need to let our configuration actions finish (so that tasks are all registered) before we can build the celery app --- src/nti/app/environments/tasks/__init__.py | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/src/nti/app/environments/tasks/__init__.py b/src/nti/app/environments/tasks/__init__.py index 70832cd9..f0ba53e2 100644 --- 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)