Merge pull request #13904 from mvdbeek/set_default_celery_app

[22.01] Set default celery app for all threads
galaxyproject · May 11, 2022 · 3dbae41 · 3dbae41
2 parents be45760 + 8f903c9
commit 3dbae41
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/lib/galaxy/celery/__init__.py b/lib/galaxy/celery/__init__.py
@@ -72,6 +72,7 @@ def get_history_audit_table_prune_interval():
 
 broker = get_broker()
 celery_app = Celery('galaxy', broker=broker, include=['galaxy.celery.tasks'])
+celery_app.set_default()
 prune_interval = get_history_audit_table_prune_interval()
 if prune_interval > 0:
     celery_app.conf.beat_schedule = {