flakes

celery/tests/worker/test_request.py

@@ -336,8 +336,8 @@ class test_Request(AppCase):
         req.task.reject_on_worker_lost = True
         req.delivery_info['redelivered'] = False
         req.on_failure(einfo)
-        req.on_reject.assert_called_with(req_logger,
-            req.connection_errors, True)
+        req.on_reject.assert_called_with(
+            req_logger, req.connection_errors, True)
 
     def test_tzlocal_is_cached(self):
         req = self.get_request(self.add.s(2, 2))

celery/worker/request.py

@@ -353,7 +353,8 @@ class Request(object):
                 )
         # (acks_late) acknowledge after result stored.
         if self.task.acks_late:
-            reject_and_requeue = (self.task.reject_on_worker_lost and
+            reject_and_requeue = (
+                self.task.reject_on_worker_lost and
                 isinstance(exc, WorkerLostError) and
                 self.delivery_info.get('redelivered', False) is False)
             if reject_and_requeue: