Check that the second task does not start computing before the first one.
(hq_env: HqEnv)
| 7 | |
| 8 | |
| 9 | def test_single_dep(hq_env: HqEnv): |
| 10 | """ |
| 11 | Check that the second task does not start computing before the first one. |
| 12 | """ |
| 13 | (job, client) = prepare_job_client(hq_env, with_worker=False) |
| 14 | hq_env.start_worker(cpus=2) |
| 15 | |
| 16 | t1 = job.program(args=bash("sleep 1; echo 'hello' > foo.txt")) |
| 17 | job.program(args=bash("cat foo.txt"), deps=[t1]) |
| 18 | submitted_job = client.submit(job) |
| 19 | |
| 20 | wait_for_job_state(hq_env, submitted_job.id, "FINISHED") |
| 21 | |
| 22 | |
| 23 | def test_dep_failed(hq_env: HqEnv): |
nothing calls this directly
no test coverage detected