(hq_env: HqEnv)
| 48 | |
| 49 | |
| 50 | def test_server_compact_scheduling(hq_env: HqEnv): |
| 51 | hq_env.start_server() |
| 52 | |
| 53 | count = 8 |
| 54 | for i in range(1, count + 1): |
| 55 | hq_env.start_workers(1, cpus=4) |
| 56 | hq_env.command(["submit", "sleep", "3"]) |
| 57 | |
| 58 | wait_for_job_state(hq_env, list(range(1, count + 1)), "FINISHED") |
| 59 | |
| 60 | workers = set() |
| 61 | for i in range(1, count + 1): |
| 62 | table = hq_env.command(["job", "info", str(i)], as_table=True) |
| 63 | worker = table.get_row_value("Workers") |
| 64 | assert worker |
| 65 | workers.add(worker) |
| 66 | assert len(workers) == 2 |
| 67 | |
| 68 | |
| 69 | def test_version_mismatch(hq_env: HqEnv): |
nothing calls this directly
no test coverage detected