We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent b5885ff commit 8303ca8Copy full SHA for 8303ca8
1 file changed
taskbadger/celery.py
@@ -138,7 +138,7 @@ def taskbadger_task(self):
138
139
@before_task_publish.connect
140
def task_publish_handler(sender=None, headers=None, **kwargs):
141
- if sender.startswith("celery.") or not Badger.is_configured():
+ if sender.startswith("celery.") or not headers or not Badger.is_configured():
142
return
143
144
celery_system = Badger.current.settings.get_system_by_id("celery")
0 commit comments