flakes

celery/app/base.py

@@ -421,7 +421,8 @@ class Celery(object):
         if self.IS_WINDOWS:
             conf = {}
         else:
-            conf = (self.conf.changes if _forking and _forking._forking_is_enabled
+            conf = (self.conf.changes
+                    if _forking and _forking._forking_is_enabled
                     else self.conf._pickleable_changes())
         return (self.main, conf, self.loader_cls,
                 self.backend_cls, self.amqp_cls, self.events_cls,

celery/worker/buckets.py

@@ -43,8 +43,9 @@ class AsyncTaskBucket(object):
     def cont(self, request, bucket, tokens):
         if not bucket.can_consume(tokens):
             hold = bucket.expected_time(tokens)
-            self.worker.timer.apply_after(hold * 1000.0,
-                self.cont, (request, bucket, tokens))
+            self.worker.timer.apply_after(
+                hold * 1000.0, self.cont, (request, bucket, tokens),
+            )
         else:
             self.callback(request)