(hq_env: HqEnv, policy: str)
| 261 | |
| 262 | @pytest.mark.parametrize("policy", ["stop", "finish-running"]) |
| 263 | def test_server_lost_no_tasks(hq_env: HqEnv, policy: str): |
| 264 | hq_env.start_server() |
| 265 | worker = hq_env.start_worker(on_server_lost=policy) |
| 266 | hq_env.kill_server() |
| 267 | time.sleep(0.5) |
| 268 | hq_env.check_process_exited(worker, expected_code=1) |
| 269 | |
| 270 | |
| 271 | def test_server_lost_stop_with_task(hq_env: HqEnv): |
nothing calls this directly
no test coverage detected