Skip to content

Commit

Permalink
test asserting tasks set removed from pool
Browse files Browse the repository at this point in the history
  • Loading branch information
wxtim committed Mar 12, 2024
1 parent b7930a5 commit bf934d7
Showing 1 changed file with 5 additions and 1 deletion.
6 changes: 5 additions & 1 deletion tests/integration/test_task_pool.py
Original file line number Diff line number Diff line change
Expand Up @@ -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'])
Expand Down

0 comments on commit bf934d7

Please sign in to comment.