(hq_env: HqEnv)
| 181 | |
| 182 | |
| 183 | def test_idle_timeout_worker_cfg(hq_env: HqEnv): |
| 184 | hq_env.start_server() |
| 185 | w = hq_env.start_worker(args=["--heartbeat", "500ms", "--idle-timeout", "1s"]) |
| 186 | time.sleep(0.5) |
| 187 | hq_env.command(["submit", "--", "sleep", "1"]) |
| 188 | time.sleep(1.0) |
| 189 | table = list_all_workers(hq_env) |
| 190 | table.check_column_value("State", 0, "RUNNING") |
| 191 | |
| 192 | time.sleep(1.5) |
| 193 | hq_env.check_process_exited(w, expected_code=0) |
| 194 | table = list_all_workers(hq_env) |
| 195 | table.check_column_value("State", 0, "IDLE TIMEOUT") |
| 196 | |
| 197 | |
| 198 | def test_worker_time_limit(hq_env: HqEnv): |
nothing calls this directly
no test coverage detected