From bf934d70a2cfc50150344fde4371635816ff2357 Mon Sep 17 00:00:00 2001 From: Tim Pillinger <26465611+wxtim@users.noreply.github.com> Date: Tue, 12 Mar 2024 10:25:04 +0000 Subject: [PATCH] test asserting tasks set removed from pool --- tests/integration/test_task_pool.py | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/tests/integration/test_task_pool.py b/tests/integration/test_task_pool.py index e076e6a4495..3d75074cf15 100644 --- a/tests/integration/test_task_pool.py +++ b/tests/integration/test_task_pool.py @@ -1476,7 +1476,11 @@ async def test_set_outputs_live( assert ( pool_get_task_ids(schd.pool) == ["1/bar", "1/foo"] ) - + # Foo should have been removed from the queue: + assert '1/foo' not in [ + i.identity for i + in schd.pool.task_queue_mgr.queues['default'].deque + ] # set foo:succeed: it should spawn baz but foo remains incomplete. schd.pool.set_prereqs_and_outputs( ["1/foo"], ["succeeded"], None, ['all'])