debug

zhu · zhu · commit 0c88bec07f27 · 2023-07-11T13:34:31.000+08:00
diff --git a/celery/contrib/testing/manager.py b/celery/contrib/testing/manager.py
@@ -215,8 +215,10 @@ def wait_until_idle(self):
         while True:
             try:
                 count = control.purge()
-            except ConnectionResetError:
+            except Exception as e:
                 # test_multiprocess_producer may trigger this exception
+                import logging
+                logging.getLogger(__name__).warning(str(e), exc_info=e)
                 continue
             if count == 0:
                 break
@@ -226,9 +228,6 @@ def wait_until_idle(self):
         while True:
             try:
                 count = sum(len(t) for t in inspect.active().values())
-            except ConnectionResetError:
-                # test_multiprocess_producer may trigger this exception
-                continue
             except ContentDisallowed:
                 # test_security_task_done may trigger this exception
                 break
