generator expressions for 2.4

celery/datastructures.py

@@ -1,3 +1,4 @@
+from __future__ import generators
 """
 
 Custom Datastructures

celery/result.py

@@ -1,3 +1,4 @@
+from __future__ import generators
 """
 
 Asynchronous result types.

celery/utils/__init__.py

@@ -1,3 +1,4 @@
+from __future__ import generators
 """
 
 Utility functions

celery/utils/compat.py

@@ -1,3 +1,4 @@
+from __future__ import generators
 ############## parse_qsl ####################################################
 try:
     from urlparse import parse_qsl

celery/worker/listener.py

@@ -1,3 +1,4 @@
+from __future__ import generators
 import socket
 import warnings
 from datetime import datetime
@@ -213,6 +214,8 @@ class CarrotListener(object):
         while 1:
             yield self.connection.connection.drain_events()
 
+        return self._mainloop(**kwargs)
+
     def _detect_wait_method(self):
         if hasattr(self.connection.connection, "drain_events"):
             self.broadcast_consumer.register_callback(self.receive_message)

celery/worker/scheduler.py

@@ -1,3 +1,4 @@
+from __future__ import generators
 import time
 import heapq