()
| 389 | |
| 390 | |
| 391 | def test_avoid_cycles(): |
| 392 | pytest.importorskip("distributed") |
| 393 | from dask._task_spec import TaskRef |
| 394 | |
| 395 | dsk = { |
| 396 | "key": TaskRef("key"), # e.g. a persisted key |
| 397 | } |
| 398 | new_dsk = convert_and_verify_keys(dsk) |
| 399 | assert not new_dsk |
| 400 | |
| 401 | |
| 402 | def test_runnable_as_kwarg(): |
nothing calls this directly
no test coverage detected
searching dependent graphs…