(expr)
| 115 | |
| 116 | |
| 117 | def create_scalar_collection(expr): |
| 118 | from dask.array._array_expr._expr import ArrayExpr |
| 119 | |
| 120 | if isinstance(expr, ArrayExpr): |
| 121 | # This mirrors the legacy implementation in dask.array |
| 122 | from dask.array._array_expr._collection import Array |
| 123 | |
| 124 | return Array(expr) |
| 125 | |
| 126 | from dask.dataframe.dask_expr._collection import Scalar |
| 127 | |
| 128 | return Scalar(expr) |