MCPcopy
hub / github.com/dask/dask / test_lazify_task

Function test_lazify_task

dask/bag/tests/test_bag.py:576–614  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

574
575
576def test_lazify_task():
577 task = Task(None, sum, Task(None, reify, Task(None, map, inc, [1, 2, 3])))
578 assert lazify_task(task) == Task(None, sum, Task(None, map, inc, [1, 2, 3]))
579
580 task = Task(None, reify, Task(None, map, inc, [1, 2, 3]))
581 assert lazify_task(task) == task
582
583 task = Task(
584 None,
585 reify,
586 Task(None, map, inc, Task(None, reify, Task(None, filter, iseven, "y"))),
587 )
588 expected = Task(None, reify, Task(None, map, inc, Task(None, filter, iseven, "y")))
589 assert lazify_task(task) == expected
590
591 task = Task(
592 None,
593 sum,
594 List(
595 Task(
596 None,
597 reify,
598 Task(None, map, inc, Task(None, reify, Task(None, filter, iseven, 1))),
599 ),
600 Task(
601 None,
602 reify,
603 Task(None, map, inc, Task(None, reify, Task(None, filter, iseven, 2))),
604 ),
605 ),
606 )
607 assert lazify_task(task) == Task(
608 None,
609 sum,
610 List(
611 Task(None, map, inc, Task(None, filter, iseven, 1)),
612 Task(None, map, inc, Task(None, filter, iseven, 2)),
613 ),
614 )
615
616
617def test_lazify_task_legacy():

Callers

nothing calls this directly

Calls 3

TaskClass · 0.90
lazify_taskFunction · 0.90
ListClass · 0.90

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…