@@ -37,15 +37,15 @@ def execute(self, msg):
37
37
try :
38
38
if settings .DEAD_LETTER_MODE :
39
39
# If in dead letter mode only try to run callback. Do not execute task.
40
- logger .info (
40
+ logger .debug (
41
41
'Task %s (%s) not executed (dead letter queue)' ,
42
42
worker_task .abs_func_name ,
43
43
worker_task .id ,
44
44
)
45
45
46
46
self ._remove_from_group (worker_task )
47
47
else :
48
- logger .info (
48
+ logger .debug (
49
49
'Execute task %s (%s) with args: %s and kwargs: %s' ,
50
50
worker_task .abs_func_name ,
51
51
worker_task .id ,
@@ -93,7 +93,7 @@ def _enqueue_task(self, worker_task, delay, execute_inline, is_retry, count_retr
93
93
94
94
self ._add_to_group (worker_task )
95
95
96
- logger .info ('%s task %s (%s): %s, %s (%s%s)' ,
96
+ logger .debug ('%s task %s (%s): %s, %s (%s%s)' ,
97
97
'Retrying' if is_retry else 'Delaying' ,
98
98
worker_task .abs_func_name ,
99
99
worker_task .id ,
@@ -139,7 +139,7 @@ def _execute_task(self, worker_task):
139
139
def _add_to_group (self , worker_task ):
140
140
# type: (WorkerTask) -> None
141
141
if worker_task .group_id and not worker_task .retry_scheduled :
142
- logger .info (
142
+ logger .debug (
143
143
'Add task %s (%s) to group %s' ,
144
144
worker_task .abs_func_name ,
145
145
worker_task .id ,
@@ -151,7 +151,7 @@ def _add_to_group(self, worker_task):
151
151
def _remove_from_group (self , worker_task ):
152
152
# type: (WorkerTask) -> None
153
153
if worker_task .group_id and not worker_task .retry_scheduled :
154
- logger .info (
154
+ logger .debug (
155
155
'Remove task %s (%s) from group %s' ,
156
156
worker_task .abs_func_name ,
157
157
worker_task .id ,
@@ -173,7 +173,7 @@ def _execute_group_callback(self, worker_task):
173
173
174
174
callback = getattr (func_module , func_name )
175
175
176
- logger .info (
176
+ logger .debug (
177
177
'All tasks in group %s finished. Trigger callback %s' ,
178
178
worker_task .group_id ,
179
179
'{}.{}' .format (callback .__module__ , callback .func_name ),
0 commit comments