1 parent d62ee4d commit ae301f0Copy full SHA for ae301f0
1 file changed
django_structlog/celery/receivers.py
@@ -137,6 +137,7 @@ def receiver_task_failure(
137
**kwargs: Any,
138
) -> None:
139
log_vars: dict[str, Any] = {}
140
+ log_vars["task_id"] = task_id
141
self.add_duration_ms(sender, log_vars)
142
throws = getattr(sender, "throws", ())
143
if isinstance(exception, throws):
0 commit comments