We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent dbf537c commit 8c5036bCopy full SHA for 8c5036b
cronitor/celery.py
@@ -36,7 +36,8 @@
36
37
def get_headers_from_task(task): # type: (celery.Task) -> Dict
38
headers = task.request.headers or {}
39
- headers.update(task.request.get('properties', {}).get('application_headers', {}))
+ request = task.request or {}
40
+ headers.update(request.get("properties", {}).get("application_headers", {}))
41
return headers
42
43
0 commit comments