소스 검색

PEP8ify + pyflakes

Ask Solem 13 년 전
부모
커밋
0bff43377e
3개의 변경된 파일3개의 추가작업 그리고 8개의 파일을 삭제
  1. 0 1
      celery/worker/autoreload.py
  2. 1 5
      celery/worker/buckets.py
  3. 2 2
      docs/internals/guide.rst

+ 0 - 1
celery/worker/autoreload.py

@@ -132,7 +132,6 @@ class KQueueMonitor(BaseMonitor):
 
     def stop(self):
         self._kq.close()
-        fds = filter(None, self.filemap.values())
         for fd in filter(None, self.filemap.values()):
             try:
                 os.close(fd)

+ 1 - 5
celery/worker/buckets.py

@@ -21,7 +21,7 @@ from __future__ import with_statement
 import threading
 
 from collections import deque
-from time import time, sleep as _sleep
+from time import time, sleep
 from Queue import Queue, Empty
 
 from kombu.utils.limits import TokenBucket
@@ -29,10 +29,6 @@ from kombu.utils.limits import TokenBucket
 from ..utils import timeutils
 from ..utils.compat import zip_longest, chain_from_iterable
 
-def sleep(n):
-    print("bucketsSLEEP: %r" % (n, ))
-    _sleep(n)
-
 
 class RateLimitExceeded(Exception):
     """The token buckets rate limit has been exceeded."""

+ 2 - 2
docs/internals/guide.rst

@@ -84,7 +84,7 @@ as this means that they can be set by either instantiation or inheritance.
         serializer = "json"
 
         def __init__(self, serializer=None):
-            self.serializer = serializer or None
+            self.serializer = serializer or self.serializer
 
             # must check for None when value can be false-y
             self.active = active if active is not None else self.active
@@ -284,7 +284,7 @@ Module Overview
 
 - celery.tests
 
-    The celery unittest suite.
+    The unittest suite.
 
 - celery.utils