flake8

celery/tests/backends/test_amqp.py

@@ -2,7 +2,6 @@ from __future__ import absolute_import
 from __future__ import with_statement
 
 import socket
-import sys
 
 from datetime import timedelta
 from Queue import Empty, Queue

celery/tests/concurrency/test_pool.py

@@ -1,6 +1,5 @@
 from __future__ import absolute_import
 
-import sys
 import time
 import itertools
 

celery/tests/concurrency/test_processes.py

@@ -2,7 +2,6 @@ from __future__ import absolute_import
 from __future__ import with_statement
 
 import signal
-import sys
 import time
 
 from itertools import cycle
@@ -10,6 +9,8 @@ from itertools import cycle
 from mock import Mock, patch
 from nose import SkipTest
 
+from celery.utils.functional import noop
+from celery.tests.utils import Case
 try:
     from celery.concurrency import processes as mp
     from billiard.pool import safe_apply_callback
@@ -35,10 +36,6 @@ except ImportError:
     mp = _mp()  # noqa
     safe_apply_callback = None  # noqa
 
-from celery.datastructures import ExceptionInfo
-from celery.utils.functional import noop
-from celery.tests.utils import Case
-
 
 class Object(object):   # for writeable attributes.
 

celery/tests/utilities/test_datastructures.py

@@ -1,11 +1,15 @@
 from __future__ import absolute_import
 from __future__ import with_statement
 
-import sys
-
-from celery.datastructures import (ExceptionInfo, LRUCache, LimitedSet,
-                                   AttributeDict, DictAttribute,
-                                   ConfigurationView, DependencyGraph)
+from celery.datastructures import (
+    ExceptionInfo,
+    LRUCache,
+    LimitedSet,
+    AttributeDict,
+    DictAttribute,
+    ConfigurationView,
+    DependencyGraph,
+)
 from celery.tests.utils import Case, WhateverIO
 
 

celery/tests/worker/test_request.py

@@ -572,7 +572,6 @@ class test_TaskRequest(Case):
         from celery.exceptions import RetryTaskError
         tid = uuid()
         mytask.request.update({"id": tid})
-        einfo = tb = None
         try:
             raise ValueError("foo")
         except Exception, exc:
@@ -581,25 +580,28 @@ class test_TaskRequest(Case):
             except RetryTaskError, exc:
                 w = TraceInfo(states.RETRY, exc)
                 w.handle_retry(mytask, store_errors=False)
-                self.assertEqual(mytask.backend.get_status(tid), states.PENDING)
+                self.assertEqual(mytask.backend.get_status(tid),
+                                 states.PENDING)
                 w.handle_retry(mytask, store_errors=True)
-                self.assertEqual(mytask.backend.get_status(tid), states.RETRY)
+                self.assertEqual(mytask.backend.get_status(tid),
+                                 states.RETRY)
         finally:
             mytask.request.clear()
 
     def test_worker_task_trace_handle_failure(self):
         tid = uuid()
         mytask.request.update({"id": tid})
-        einfo = None
         try:
             try:
                 raise ValueError("foo")
             except Exception, exc:
                 w = TraceInfo(states.FAILURE, exc)
                 w.handle_failure(mytask, store_errors=False)
-                self.assertEqual(mytask.backend.get_status(tid), states.PENDING)
+                self.assertEqual(mytask.backend.get_status(tid),
+                                 states.PENDING)
                 w.handle_failure(mytask, store_errors=True)
-                self.assertEqual(mytask.backend.get_status(tid), states.FAILURE)
+                self.assertEqual(mytask.backend.get_status(tid),
+                                 states.FAILURE)
         finally:
             mytask.request.clear()
 

celery/tests/worker/test_worker.py

@@ -2,7 +2,6 @@ from __future__ import absolute_import
 from __future__ import with_statement
 
 import socket
-import sys
 
 from collections import deque
 from datetime import datetime, timedelta