(hq_env: HqEnv)
| 90 | |
| 91 | |
| 92 | def test_worker_stop_some(hq_env: HqEnv): |
| 93 | hq_env.start_server() |
| 94 | processes = [hq_env.start_worker() for _ in range(3)] |
| 95 | |
| 96 | wait_for_worker_state(hq_env, [1, 2, 3], "RUNNING") |
| 97 | r = hq_env.command(["worker", "stop", "1-4"]) |
| 98 | wait_for_worker_state(hq_env, [1, 2, 3], "STOPPED", check_running_processes=False) |
| 99 | |
| 100 | for process in processes: |
| 101 | hq_env.check_process_exited(process) |
| 102 | assert "Stopping worker 4 failed" in r |
| 103 | |
| 104 | |
| 105 | def test_worker_stop_all(hq_env: HqEnv): |
nothing calls this directly
no test coverage detected