File tree Expand file tree Collapse file tree 1 file changed +6
-0
lines changed Expand file tree Collapse file tree 1 file changed +6
-0
lines changed Original file line number Diff line number Diff line change 8
8
from sentry_sdk .hub import Hub
9
9
from sentry_sdk .utils import capture_internal_exceptions , event_from_exception
10
10
from sentry_sdk .integrations import Integration
11
+ from sentry_sdk .integrations .logging import ignore_logger
11
12
12
13
13
14
class CeleryIntegration (Integration ):
@@ -19,6 +20,11 @@ def setup_once():
19
20
task_postrun .connect (_handle_task_postrun , weak = False )
20
21
task_failure .connect (_process_failure_signal , weak = False )
21
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
+
22
28
23
29
def _process_failure_signal (sender , task_id , einfo , ** kw ):
24
30
# einfo from celery is not reliable
You can’t perform that action at this time.
0 commit comments