소스 검색

Hub: Handle poll if poller closed. Fixes #882

Ask Solem 12 년 전
부모
커밋
6b5461c0a0
1개의 변경된 파일5개의 추가작업 그리고 1개의 파일을 삭제
  1. 5 1
      celery/worker/consumer.py

+ 5 - 1
celery/worker/consumer.py

@@ -440,7 +440,11 @@ class Consumer(object):
                 if readers or writers:
                     connection.more_to_read = True
                     while connection.more_to_read:
-                        for fileno, event in poll(poll_timeout) or ():
+                        try:
+                            events = poll(poll_timeout):
+                        except ValueError:  # Issue 882
+                            return
+                        for fileno, event in events or ():
                             try:
                                 if event & READ:
                                     readers[fileno](fileno, event)