(ddf, scheduler=None)
| 600 | |
| 601 | |
| 602 | def assert_divisions(ddf, scheduler=None): |
| 603 | if not hasattr(ddf, "divisions"): |
| 604 | return |
| 605 | |
| 606 | assert isinstance(ddf.divisions, tuple) |
| 607 | |
| 608 | if not getattr(ddf, "known_divisions", False): |
| 609 | return |
| 610 | |
| 611 | ddf.enforce_runtime_divisions().compute(scheduler=scheduler) |
| 612 | |
| 613 | |
| 614 | def assert_sane_keynames(ddf): |
searching dependent graphs…