(hq_env: HqEnv)
| 115 | |
| 116 | |
| 117 | def test_worker_stop_last(hq_env: HqEnv): |
| 118 | hq_env.start_server() |
| 119 | processes = [hq_env.start_worker() for _ in range(4)] |
| 120 | |
| 121 | wait_for_worker_state(hq_env, [1, 2, 3, 4], ["RUNNING" for _ in range(4)]) |
| 122 | hq_env.command(["worker", "stop", "last"]) |
| 123 | wait_for_worker_state(hq_env, [4], ["STOPPED" for _ in range(4)], check_running_processes=False) |
| 124 | |
| 125 | hq_env.check_process_exited(processes[3]) |
| 126 | |
| 127 | |
| 128 | def test_worker_list_only_online(hq_env: HqEnv): |
nothing calls this directly
no test coverage detected