Skip to content

Commit

Permalink
Add first array draft (#1090)
Browse files Browse the repository at this point in the history
  • Loading branch information
fjetter authored Jun 25, 2024
1 parent d0e0c21 commit 3997b82
Show file tree
Hide file tree
Showing 11 changed files with 3,719 additions and 0 deletions.
1 change: 1 addition & 0 deletions ci/environment.yml
Original file line number Diff line number Diff line change
Expand Up @@ -9,6 +9,7 @@ dependencies:
- pyarrow>=7
- pandas>=2
- pre-commit
- xarray
- pip:
- git+https://github.com/dask/distributed
- git+https://github.com/dask/dask
3 changes: 3 additions & 0 deletions dask_expr/_core.py
Original file line number Diff line number Diff line change
Expand Up @@ -150,6 +150,9 @@ def pprint(self):
def __hash__(self):
return hash(self._name)

def __dask_tokenize__(self):
return self._name

def __reduce__(self):
if dask.config.get("dask-expr-no-serialize", False):
raise RuntimeError(f"Serializing a {type(self)} object")
Expand Down
14 changes: 14 additions & 0 deletions dask_expr/array/__init__.py
Original file line number Diff line number Diff line change
@@ -0,0 +1,14 @@
from dask_expr.array import random
from dask_expr.array.core import Array, from_array
from dask_expr.array.reductions import (
mean,
moment,
nanmean,
nanstd,
nansum,
nanvar,
prod,
std,
sum,
var,
)
Loading

0 comments on commit 3997b82

Please sign in to comment.