MCPcopy
hub / github.com/dask/dask / test_execute_tasks_in_graph

Function test_execute_tasks_in_graph

dask/tests/test_task_spec.py:725–734  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

723
724
725def test_execute_tasks_in_graph():
726 dsk = [
727 t1 := Task("key-1", func, "a", "b"),
728 t2 := Task("key-2", func2, t1.ref(), "c"),
729 t3 := Task("key-3", func, "foo", "bar"),
730 Task("key-4", func, t3.ref(), t2.ref()),
731 ]
732 res = execute_graph(dsk, keys=["key-4"])
733 assert len(res) == 1
734 assert res["key-4"] == "foo-bar-a-b=c"
735
736
737def test_deterministic_tokenization_respected():

Callers

nothing calls this directly

Calls 3

TaskClass · 0.90
execute_graphFunction · 0.90
refMethod · 0.80

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…