flakes

marcusmartins · Mar 6, 2013 · f9f2081 · f9f2081
1 parent 7fd158b
commit f9f2081
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/celery/app/base.py b/celery/app/base.py
@@ -20,8 +20,8 @@
 
 try:
     from billiard import forking as _forking
-except ImportError:
-    _forking = None
+except ImportError:  # pragma: no cover
+    _forking = None  # noqa
 from billiard.util import register_after_fork
 from kombu.clocks import LamportClock
 from kombu.utils import cached_property

diff --git a/celery/worker/consumer.py b/celery/worker/consumer.py
@@ -453,7 +453,8 @@ def on_task_received(body, message):
 
                 # fire any ready timers, this also returns
                 # the number of seconds until we need to fire timers again.
-                poll_timeout = fire_timers(propagate=errors) if scheduled else 1
+                poll_timeout = (fire_timers(propagate=errors) if scheduled
+                                else 1)
 
                 # We only update QoS when there is no more messages to read.
                 # This groups together qos calls, and makes sure that remote