We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 3ee47b7 commit eb98703Copy full SHA for eb98703
1 file changed
sentry_sdk/integrations/celery.py
@@ -8,6 +8,7 @@
8
from sentry_sdk.hub import Hub
9
from sentry_sdk.utils import capture_internal_exceptions, event_from_exception
10
from sentry_sdk.integrations import Integration
11
+from sentry_sdk.integrations.logging import ignore_logger
12
13
14
class CeleryIntegration(Integration):
@@ -19,6 +20,11 @@ def setup_once():
19
20
task_postrun.connect(_handle_task_postrun, weak=False)
21
task_failure.connect(_process_failure_signal, weak=False)
22
23
+ # This logger logs every status of every task that ran on the worker.
24
+ # Meaning that every task's breadcrumbs are full of stuff like "Task
25
+ # <foo> raised unexpected <bar>".
26
+ ignore_logger("celery.worker.job")
27
+
28
29
def _process_failure_signal(sender, task_id, einfo, **kw):
30
# einfo from celery is not reliable
0 commit comments