Ask Solem před 12 roky
rodič
revize
eb71e24b17

+ 1 - 1
celery/bin/celery.py

@@ -31,7 +31,7 @@ try:
     # print_statement does not work with io.StringIO
     from io import BytesIO as PrintIO
 except ImportError:
-    from StringIO import StringIO as PrintIO
+    from StringIO import StringIO as PrintIO  # noqa
 
 HELP = """
 ---- -- - - ---- Commands- -------------- --- ------------

+ 1 - 1
celery/tests/bin/test_celeryd.py

@@ -289,7 +289,7 @@ class test_Worker(WorkerAppCase):
 
     @disable_stdouts
     def test_redirect_stdouts(self):
-        worker = self.Worker(redirect_stdouts=False)
+        self.Worker(redirect_stdouts=False)
         with self.assertRaises(AttributeError):
             sys.stdout.logger
 

+ 0 - 1
celery/worker/__init__.py

@@ -130,7 +130,6 @@ class WorkController(configurated):
                                    on_stopped=self.on_stopped)
         self.namespace.apply(self, **kwargs)
 
-
     def on_init_namespace(self):
         pass
 

+ 0 - 1
celery/worker/bootsteps.py

@@ -201,7 +201,6 @@ def _prepare_requires(req):
     return req
 
 
-
 class ComponentType(type):
     """Metaclass for components."""
 

+ 1 - 0
celery/worker/state.py

@@ -20,6 +20,7 @@ from collections import defaultdict
 from kombu.utils import cached_property
 
 from celery import __version__
+from celery.exceptions import SystemTerminate
 from celery.datastructures import LimitedSet
 
 #: Worker software/platform information.