pep8/cosmetics

celery/app/base.py

@@ -18,7 +18,6 @@ from copy import deepcopy
 from functools import wraps
 from operator import attrgetter
 
-from billiard import forking as _forking
 from billiard.util import register_after_fork
 from kombu.clocks import LamportClock
 from kombu.utils import cached_property

celery/backends/amqp.py

@@ -163,7 +163,7 @@ class AMQPBackend(BaseBackend):
             binding.declare()
 
             prev = latest = acc = None
-            for i in range(backlog_limit):  ## spool ffwd
+            for i in range(backlog_limit):  # spool ffwd
                 prev, latest, acc = latest, acc, binding.get(no_ack=False)
                 if not acc:  # no more messages
                     break

celery/signals.py

@@ -16,13 +16,16 @@ from __future__ import absolute_import
 from .utils.dispatch import Signal
 
 task_sent = Signal(providing_args=[
-    'task_id', 'task', 'args', 'kwargs', 'eta', 'taskset'])
+    'task_id', 'task', 'args', 'kwargs', 'eta', 'taskset',
+])
 task_prerun = Signal(providing_args=['task_id', 'task', 'args', 'kwargs'])
 task_postrun = Signal(providing_args=[
-    'task_id', 'task', 'args', 'kwargs', 'retval'])
+    'task_id', 'task', 'args', 'kwargs', 'retval',
+])
 task_success = Signal(providing_args=['result'])
 task_failure = Signal(providing_args=[
-    'task_id', 'exception', 'args', 'kwargs', 'traceback', 'einfo'])
+    'task_id', 'exception', 'args', 'kwargs', 'traceback', 'einfo',
+])
 task_revoked = Signal(providing_args=['terminated', 'signum', 'expired'])
 celeryd_init = Signal(providing_args=['instance', 'conf'])
 celeryd_after_setup = Signal(providing_args=['instance', 'conf'])
@@ -31,11 +34,14 @@ worker_process_init = Signal(providing_args=[])
 worker_ready = Signal(providing_args=[])
 worker_shutdown = Signal(providing_args=[])
 setup_logging = Signal(providing_args=[
-    'loglevel', 'logfile', 'format', 'colorize'])
+    'loglevel', 'logfile', 'format', 'colorize',
+])
 after_setup_logger = Signal(providing_args=[
-    'logger', 'loglevel', 'logfile', 'format', 'colorize'])
+    'logger', 'loglevel', 'logfile', 'format', 'colorize',
+])
 after_setup_task_logger = Signal(providing_args=[
-    'logger', 'loglevel', 'logfile', 'format', 'colorize'])
+    'logger', 'loglevel', 'logfile', 'format', 'colorize',
+])
 beat_init = Signal(providing_args=[])
 beat_embedded_init = Signal(providing_args=[])
 eventlet_pool_started = Signal(providing_args=[])