@@ -21,7 +21,7 @@ def apply_async(self, args=None, kwargs=None, **options): # pylint: disable=arg
2121 """
2222 Emit a log statement when the task is submitted.
2323 """
24- result = super (LoggedTask , self ).apply_async (args = args , kwargs = kwargs , ** options )
24+ result = super ().apply_async (args = args , kwargs = kwargs , ** options )
2525 log .info ('Task {}[{}] submitted with arguments {}, {}' .format (
2626 self .name ,
2727 result .id ,
@@ -34,12 +34,12 @@ def on_retry(self, exc, task_id, args, kwargs, einfo):
3434 """
3535 Capture the exception that caused the task to be retried, if any.
3636 """
37- super (LoggedTask , self ).on_retry (exc , task_id , args , kwargs , einfo )
37+ super ().on_retry (exc , task_id , args , kwargs , einfo )
3838 log .warning ('[{}] retried due to {}' .format (task_id , getattr (einfo , 'traceback' , None )))
3939
4040 def on_failure (self , exc , task_id , args , kwargs , einfo ):
4141 """
4242 Capture the exception that caused the task to fail, if any.
4343 """
4444 log .error ('[{}] failed due to {}' .format (task_id , getattr (einfo , 'traceback' , None )))
45- super (LoggedTask , self ).on_failure (exc , task_id , args , kwargs , einfo )
45+ super ().on_failure (exc , task_id , args , kwargs , einfo )
0 commit comments