(*exprs, divisions)
| 4114 | |
| 4115 | |
| 4116 | def maybe_align_partitions(*exprs, divisions): |
| 4117 | from dask.dataframe.dask_expr._repartition import Repartition |
| 4118 | |
| 4119 | return [ |
| 4120 | ( |
| 4121 | Repartition(df, new_divisions=divisions, force=True) |
| 4122 | if isinstance(df, Expr) and df.ndim > 0 |
| 4123 | else df |
| 4124 | ) |
| 4125 | for df in exprs |
| 4126 | ] |
| 4127 | |
| 4128 | |
| 4129 | def _extract_meta(x, nonempty=False): |
no test coverage detected