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