r""" aa / | b d bb dd / \ /| | / a c e cc
(abcde)
| 536 | |
| 537 | |
| 538 | def test_run_smaller_sections(abcde): |
| 539 | r""" |
| 540 | aa |
| 541 | / | |
| 542 | b d bb dd |
| 543 | / \ /| | / |
| 544 | a c e cc |
| 545 | |
| 546 | """ |
| 547 | a, b, c, d, e = abcde |
| 548 | aa, bb, cc, dd = (x * 2 for x in [a, b, c, d]) |
| 549 | |
| 550 | dsk = { |
| 551 | a: (f,), |
| 552 | c: (f,), |
| 553 | e: (f,), |
| 554 | cc: (f,), |
| 555 | b: (f, a, c), |
| 556 | d: (f, c, e), |
| 557 | bb: (f, cc), |
| 558 | aa: (f, d, bb), |
| 559 | dd: (f, cc), |
| 560 | } |
| 561 | o = order(dsk) |
| 562 | assert_topological_sort(dsk, o) |
| 563 | # The actual order is a bit ambiguous but the optimal pressure is well |
| 564 | # defined, see also |
| 565 | # https://github.com/dask/dask/pull/10535/files#r1337528255 |
| 566 | assert max(diagnostics(dsk)[1]) == 3 |
| 567 | |
| 568 | |
| 569 | def test_local_parents_of_reduction(abcde): |
nothing calls this directly
no test coverage detected