@@ -67,6 +67,7 @@
terminated and replaced by a new worker.
"""
+import sys
import multiprocessing
from celery.bin.base import Command, Option
@@ -158,7 +159,6 @@ def main():
worker.execute_from_commandline()
-
def windows_main():
sys.stderr.write("""
@@ -1,7 +1,6 @@
import time
import heapq
-from collections import deque
from threading import Lock
from carrot.utils import partition
@@ -210,7 +210,6 @@ class test_State(unittest.TestCase):
self.assertTrue(state.event_count)
self.assertTrue(state.task_count)
def test_freeze_while(self):
s = State()
r = ev_snapshot(s)