MCPcopy Create free account
hub / github.com/dask/dask / test_fuse_tasks_key

Function test_fuse_tasks_key

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

Source from the content-addressed store, hash-verified

773
774
775def test_fuse_tasks_key():
776 a = Task("key-1", func, "a", "b")
777 b = Task("key-2", func2, a.ref(), "d")
778 for t1, t2 in itertools.permutations((a, b)):
779 fused = Task.fuse(t2, t1)
780 assert fused.key == b.key
781
782 fused = Task.fuse(t2, t1, key="new-key")
783 assert fused.key == "new-key"
784
785
786def test_fuse_tasks():

Callers

nothing calls this directly

Calls 3

TaskClass · 0.90
refMethod · 0.80
fuseMethod · 0.45

Tested by

no test coverage detected