@@ -37,15 +37,15 @@ def execute(self, msg):
3737 try :
3838 if settings .DEAD_LETTER_MODE :
3939 # If in dead letter mode only try to run callback. Do not execute task.
40- logger .info (
40+ logger .debug (
4141 'Task %s (%s) not executed (dead letter queue)' ,
4242 worker_task .abs_func_name ,
4343 worker_task .id ,
4444 )
4545
4646 self ._remove_from_group (worker_task )
4747 else :
48- logger .info (
48+ logger .debug (
4949 'Execute task %s (%s) with args: %s and kwargs: %s' ,
5050 worker_task .abs_func_name ,
5151 worker_task .id ,
@@ -93,7 +93,7 @@ def _enqueue_task(self, worker_task, delay, execute_inline, is_retry, count_retr
9393
9494 self ._add_to_group (worker_task )
9595
96- logger .info ('%s task %s (%s): %s, %s (%s%s)' ,
96+ logger .debug ('%s task %s (%s): %s, %s (%s%s)' ,
9797 'Retrying' if is_retry else 'Delaying' ,
9898 worker_task .abs_func_name ,
9999 worker_task .id ,
@@ -139,7 +139,7 @@ def _execute_task(self, worker_task):
139139 def _add_to_group (self , worker_task ):
140140 # type: (WorkerTask) -> None
141141 if worker_task .group_id and not worker_task .retry_scheduled :
142- logger .info (
142+ logger .debug (
143143 'Add task %s (%s) to group %s' ,
144144 worker_task .abs_func_name ,
145145 worker_task .id ,
@@ -151,7 +151,7 @@ def _add_to_group(self, worker_task):
151151 def _remove_from_group (self , worker_task ):
152152 # type: (WorkerTask) -> None
153153 if worker_task .group_id and not worker_task .retry_scheduled :
154- logger .info (
154+ logger .debug (
155155 'Remove task %s (%s) from group %s' ,
156156 worker_task .abs_func_name ,
157157 worker_task .id ,
@@ -173,7 +173,7 @@ def _execute_group_callback(self, worker_task):
173173
174174 callback = getattr (func_module , func_name )
175175
176- logger .info (
176+ logger .debug (
177177 'All tasks in group %s finished. Trigger callback %s' ,
178178 worker_task .group_id ,
179179 '{}.{}' .format (callback .__module__ , callback .func_name ),
0 commit comments