Happify linter.

Author: Omer Katz

celery/app/autoretry.py

@@ -48,9 +48,9 @@ def run(*args, **kwargs):
                             full_jitter=retry_jitter)
                 # Override max_retries
                 if hasattr(task, 'override_max_retries'):
-                    retry_kwargs['max_retries'] =  getattr(task,
-                                                      'override_max_retries',
-                                                      task.max_retries)
+                    retry_kwargs['max_retries'] = getattr(task,
+                                                          'override_max_retries',
+                                                          task.max_retries)
                 ret = task.retry(exc=exc, **retry_kwargs)
                 # Stop propagation
                 if hasattr(task, 'override_max_retries'):

celery/exceptions.py

@@ -293,4 +293,3 @@ def __init__(self, *args, **kwargs):
 
     def __repr__(self):
         return super().__repr__() + " state:" + self.state + " task_id:" + self.task_id
-

t/integration/test_canvas.py

@@ -1239,6 +1239,7 @@ class test_signature_serialization:
     signature object was not properly deserialized from its dictionary
     representation, and would explode later on if it were used as a signature.
     """
+
     def test_rebuild_nested_chain_chain(self, manager):
         sig = chain(
             tasks.return_nested_signature_chain_chain.s(),

t/unit/worker/test_request.py

@@ -1205,7 +1205,7 @@ def test_execute_using_pool_with_none_timelimit_header(self):
     def test_execute_using_pool__defaults_of_hybrid_to_proto2(self):
         weakref_ref = Mock(name='weakref.ref')
         headers = strategy.hybrid_to_proto2(Mock(headers=None), {'id': uuid(),
-                                            'task': self.mytask.name})[1]
+                                                                 'task': self.mytask.name})[1]
         job = self.zRequest(revoked_tasks=set(), ref=weakref_ref, **headers)
         job.execute_using_pool(self.pool)
         assert job._apply_result