(hq_env: HqEnv)
| 161 | |
| 162 | |
| 163 | def test_task_resource_fractions_scatter(hq_env: HqEnv): |
| 164 | hq_env.start_server() |
| 165 | hq_env.start_worker(cpus=4, args=["--resource", "foo=[[a,b,c],[i, j, k],[x, y],[v, w]]"]) |
| 166 | |
| 167 | hq_env.command( |
| 168 | [ |
| 169 | "submit", |
| 170 | "--resource", |
| 171 | "foo=3.5", |
| 172 | "--", |
| 173 | "bash", |
| 174 | "-c", |
| 175 | "echo $HQ_RESOURCE_VALUES_foo", |
| 176 | ] |
| 177 | ) |
| 178 | wait_for_job_state(hq_env, 1, "FINISHED") |
| 179 | with open(default_task_output()) as f: |
| 180 | r = f.readline().rstrip().split(",") |
| 181 | assert len(r) == 4 |
| 182 | assert len(set(r)) == 4 |
| 183 | |
| 184 | |
| 185 | def test_task_resource_fractions_sum2(hq_env: HqEnv): |
nothing calls this directly
no test coverage detected