Skip to content

Commit 5f33d30

Browse files
committed
filter out celery heartbeat
1 parent a3000cf commit 5f33d30

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

sentry_sdk/integrations/celery/__init__.py

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -533,7 +533,11 @@ def sentry_publish(self: "Producer", *args: "Any", **kwargs: "Any") -> "Any":
533533
# method will still work.
534534
kwargs_headers = {}
535535

536-
task_name = kwargs_headers.get("task") or "unknown celery task"
536+
if "task" not in kwargs_headers:
537+
# filter out heartbeat and other internal Celery events
538+
return original_publish(self, *args, **kwargs)
539+
540+
task_name = kwargs_headers.get("task")
537541
task_id = kwargs_headers.get("id")
538542
retries = kwargs_headers.get("retries")
539543

0 commit comments

Comments
 (0)