(hq_env: HqEnv)
| 75 | |
| 76 | |
| 77 | def test_worker_stop(hq_env: HqEnv): |
| 78 | hq_env.start_server() |
| 79 | process = hq_env.start_worker() |
| 80 | |
| 81 | wait_for_worker_state(hq_env, 1, "RUNNING") |
| 82 | hq_env.command(["worker", "stop", "1"]) |
| 83 | wait_for_worker_state(hq_env, 1, "STOPPED", check_running_processes=False) |
| 84 | hq_env.check_process_exited(process) |
| 85 | |
| 86 | response = hq_env.command(["worker", "stop", "1"]) |
| 87 | assert "worker is already stopped" in response |
| 88 | response = hq_env.command(["worker", "stop", "2"]) |
| 89 | assert "worker not found" in response |
| 90 | |
| 91 | |
| 92 | def test_worker_stop_some(hq_env: HqEnv): |
nothing calls this directly
no test coverage detected