(ddf, scheduler=None)
| 596 | |
| 597 | |
| 598 | def assert_divisions(ddf, scheduler=None): |
| 599 | if not hasattr(ddf, "divisions"): |
| 600 | return |
| 601 | |
| 602 | assert isinstance(ddf.divisions, tuple) |
| 603 | |
| 604 | if not getattr(ddf, "known_divisions", False): |
| 605 | return |
| 606 | |
| 607 | ddf.enforce_runtime_divisions().compute(scheduler=scheduler) |
| 608 | |
| 609 | |
| 610 | def assert_sane_keynames(ddf): |