Browse Source

[asynpool] Fixed typo in on_stop_not_started possibly extending shutdown time (Issue #2606)

Ask Solem 8 years ago
parent
commit
320777611a
1 changed files with 1 additions and 1 deletions
  1. 1 1
      celery/concurrency/asynpool.py

+ 1 - 1
celery/concurrency/asynpool.py

@@ -319,7 +319,7 @@ class ResultHandler(_pool.ResultHandler):
             pending_remove_fd = set()
             for fd in outqueues:
                 self._flush_outqueue(
-                    fd, pending_remove_fd.discard, fileno_to_outq,
+                    fd, pending_remove_fd.add, fileno_to_outq,
                     on_state_change,
                 )
                 try: