Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Flow-specific hold/release #5698

Draft
wants to merge 18 commits into
base: master
Choose a base branch
from
Draft

Flow-specific hold/release #5698

Changes from 1 commit
Commits
Show all changes
18 commits
Select commit Hold shift click to select a range
e8d957c
Task pool flow hold.
hjoliver Aug 16, 2023
58dc6c5
Future flow hold.
hjoliver Aug 17, 2023
95fa798
Flow-specific hold release.
hjoliver Aug 17, 2023
1e7d548
Centralise task hold/release code.
hjoliver Aug 20, 2023
b5f83a4
Style fixes.
hjoliver Aug 21, 2023
584bea8
Fix integration tests.
hjoliver Aug 22, 2023
77acf44
fix hold on kill
hjoliver Aug 22, 2023
ad81aa3
Fix func tests.
hjoliver Aug 22, 2023
2b570d5
Fix more func tests.
hjoliver Aug 24, 2023
ff07668
Update change log.
hjoliver Aug 28, 2023
d3c776c
Fix hold on kill.
hjoliver Aug 31, 2023
b2e7440
hold mgr: clear not needed.
hjoliver Aug 31, 2023
151537e
Validate CLI --flow opt.
hjoliver Aug 31, 2023
f554c96
Update flow hold integration tests.
hjoliver Sep 1, 2023
6597431
fix release from hold.
hjoliver Sep 1, 2023
e1fb7fe
Update flow release integration tests.
hjoliver Sep 1, 2023
9e93454
hold_point with flow num
hjoliver Sep 1, 2023
e912f63
Fix recent.
hjoliver Sep 1, 2023
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Update flow release integration tests.
  • Loading branch information
@hjoliver
hjoliver committed Sep 1, 2023
commit e1fb7fef643f8da328dc66ab5df4f0e1f1868d19
12 changes: 10 additions & 2 deletions tests/integration/test_task_pool.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -450,16 450,24 @@ async def test_release_held_tasks(
assert get_task_ids(db_tasks_to_hold) == expected_tasks_to_hold_ids

# Test
task_pool.release_held_tasks(['1/foo', '3/asd'])
task_pool.release_held_tasks(['1/foo', '3/asd'], 1) # right flow, do release
for itask in task_pool.get_all_tasks():
assert itask.state.is_held is (itask.identity == '1/bar')

expected_tasks_to_hold_ids = sorted(['1/bar'])
task_pool.release_held_tasks(['1/bar'], 2) # wrong flow, don't release
for itask in task_pool.get_all_tasks():
assert itask.state.is_held is (itask.identity == '1/bar')

expected_tasks_to_hold_ids = ['1/bar']
assert get_task_ids(task_pool.hold_mgr._flatten()) == expected_tasks_to_hold_ids

db_tasks_to_hold = db_select(example_flow, True, 'tasks_to_hold')
assert get_task_ids(db_tasks_to_hold) == expected_tasks_to_hold_ids

task_pool.release_held_tasks(['1/bar']) # any flow, do release
for itask in task_pool.get_all_tasks():
assert itask.state.is_held is False


@pytest.mark.parametrize(
'hold_after_point, expected_held_task_ids',
Expand Down