(hq_env: HqEnv)
| 246 | |
| 247 | |
| 248 | def test_resources_task(hq_env: HqEnv): |
| 249 | (job, client) = prepare_job_client(hq_env) |
| 250 | |
| 251 | job.program( |
| 252 | args=bash("echo Hello"), |
| 253 | resources=ResourceRequest(cpus="2", resources={"res0": 1, "res1": 105.1}), |
| 254 | ) |
| 255 | submitted_job = client.submit(job) |
| 256 | wait_for_job_state(hq_env, 1, "WAITING") |
| 257 | |
| 258 | table = hq_env.command(["task", "info", str(submitted_job.id), "0"], as_table=True) |
| 259 | table.check_row_value("Resources", "cpus: 2 compact\nres0: 1 compact\nres1: 105.1 compact") |
| 260 | |
| 261 | |
| 262 | def test_priority_task(hq_env: HqEnv): |
nothing calls this directly
no test coverage detected