(*exprs, divisions)
| 4070 | |
| 4071 | |
| 4072 | def maybe_align_partitions(*exprs, divisions): |
| 4073 | from dask.dataframe.dask_expr._repartition import Repartition |
| 4074 | |
| 4075 | return [ |
| 4076 | ( |
| 4077 | Repartition(df, new_divisions=divisions, force=True) |
| 4078 | if isinstance(df, Expr) and df.ndim > 0 |
| 4079 | else df |
| 4080 | ) |
| 4081 | for df in exprs |
| 4082 | ] |
| 4083 | |
| 4084 | |
| 4085 | def _extract_meta(x, nonempty=False): |
no test coverage detected