Stabilized test_revoked_by_headers_complex_canvas

celery · Nov 2, 2022 · e12a701 · e12a701
1 parent 720d192
commit e12a701
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/t/integration/test_tasks.py b/t/integration/test_tasks.py
@@ -242,6 +242,11 @@ def test_revoked_by_headers_complex_canvas(self, manager, subtests, monitoring_i
         except NotImplementedError as e:
             raise pytest.skip(e.args[0])
 
+        while True:
+            count = manager.app.control.purge()
+            if count == 0:
+                break
+
         target_monitoring_id = isinstance(monitoring_id, list) and monitoring_id[0] or monitoring_id
 
         class MonitoringIdStampingVisitor(StampingVisitor):