(hq_env: HqEnv)
| 149 | |
| 150 | |
| 151 | def test_worker_list_resources(hq_env: HqEnv): |
| 152 | hq_env.start_server() |
| 153 | hq_env.start_worker(cpus="10") |
| 154 | hq_env.start_worker(cpus="4x5") |
| 155 | hq_env.start_worker(cpus="[[100, 200, 300], [400, 500, 600]]") |
| 156 | hq_env.start_worker(cpus="[[0, 1], [2], [10, 11, 12]]") |
| 157 | |
| 158 | wait_for_worker_state(hq_env, [1, 2, 3, 4], "RUNNING") |
| 159 | |
| 160 | table = list_all_workers(hq_env) |
| 161 | assert len(table) == 4 |
| 162 | table.check_columns_value(["ID", "State", "Resources"], 0, ["1", "RUNNING", "cpus 10"]) |
| 163 | table.check_columns_value(["ID", "State", "Resources"], 1, ["2", "RUNNING", "cpus 4x5"]) |
| 164 | table.check_columns_value(["ID", "State", "Resources"], 2, ["3", "RUNNING", "cpus 2x3"]) |
| 165 | table.check_columns_value(["ID", "State", "Resources"], 3, ["4", "RUNNING", "cpus 1x1 1x2 1x3"]) |
| 166 | |
| 167 | |
| 168 | def test_idle_timeout_server_cfg(hq_env: HqEnv): |
nothing calls this directly
no test coverage detected