.flake8
.gitignore
.pre-commit-config.yaml
LICENSE
cascade.png
justfile
pyproject.toml
readme.md
research-and-development.md
roadmap.md
setup.py
.github/ci-config.yml
.github/ci-hpc-config.yml
.github/workflows/cd-pypi.yml
.github/workflows/ci.yml
.github/workflows/label-public-prs.yml
.github/workflows/macos-test.yml
.github/workflows/test-pypi.yml
docs/cascadeFeatures.md
docs/ensemble_percentiles.ipynb
docs/introduction.md
docs/reduce.png
docs/benchmarking/postproc.sh
docs/benchmarking/slurm_entrypoint.sh
docs/benchmarking/slurm_submit.sh
docs/benchmarking/run1/analysis.ipynb
docs/benchmarking/run1/analysis.py
docs/benchmarking/run2/analysis.ipynb
docs/benchmarking/run2/analysis.py
docs/benchmarking/run3/notes.txt
docs/benchmarking/run3/prototype_allocationviz.py
docs/benchmarking/run3/tasklanes.ipynb
docs/benchmarking/run3/tasklanes.py
docs/examples/arrayapi.ipynb
docs/examples/rasm.nc
docs/examples/xarray.ipynb
docs/generators_in_dask/code.py
docs/ideas/fluent_api_extension.md
scripts/example_config.sh
scripts/launch_slurm.sh
scripts/slurm_entrypoint.sh
src/cascade/__init__.py
src/cascade/py.typed
src/cascade/benchmarks/__init__.py
src/cascade/benchmarks/__main__.py
src/cascade/benchmarks/anemoi.py
src/cascade/benchmarks/dask.py
src/cascade/benchmarks/dist.py
src/cascade/benchmarks/generators.py
src/cascade/benchmarks/job1.py
src/cascade/benchmarks/matmul.py
src/cascade/benchmarks/plotting.py
src/cascade/benchmarks/reporting.py
src/cascade/benchmarks/util.py
src/cascade/controller/__init__.py
src/cascade/controller/act.py
src/cascade/controller/core.py
src/cascade/controller/impl.py
src/cascade/controller/notify.py
src/cascade/controller/report.py
src/cascade/executor/bridge.py
src/cascade/executor/comms.py
src/cascade/executor/config.py
src/cascade/executor/data_server.py
src/cascade/executor/executor.py
src/cascade/executor/msg.py
src/cascade/executor/platform.py
src/cascade/executor/serde.py
src/cascade/executor/runner/__init__.py
src/cascade/executor/runner/entrypoint.py
src/cascade/executor/runner/memory.py
src/cascade/executor/runner/packages.py
src/cascade/executor/runner/runner.py
src/cascade/gateway/__init__.py
src/cascade/gateway/__main__.py
src/cascade/gateway/api.py
src/cascade/gateway/client.py
src/cascade/gateway/router.py
src/cascade/gateway/server.py
src/cascade/low/__init__.py
src/cascade/low/builders.py
src/cascade/low/core.py
src/cascade/low/dask.py
src/cascade/low/execution_context.py
src/cascade/low/func.py
src/cascade/low/into.py
src/cascade/low/tracing.py
src/cascade/low/views.py
src/cascade/scheduler/__init__.py
src/cascade/scheduler/api.py
src/cascade/scheduler/assign.py
src/cascade/scheduler/core.py
src/cascade/scheduler/precompute.py
src/cascade/shm/__init__.py
src/cascade/shm/algorithms.py
src/cascade/shm/api.py
src/cascade/shm/client.py
src/cascade/shm/dataset.py
src/cascade/shm/disk.py
src/cascade/shm/func.py
src/cascade/shm/server.py
src/earthkit/workflows/__init__.py
src/earthkit/workflows/_version.py
src/earthkit/workflows/decorators.py
src/earthkit/workflows/fluent.py
src/earthkit/workflows/mark.py
src/earthkit/workflows/py.typed
src/earthkit/workflows/taskgraph.py
src/earthkit/workflows/transformers.py
src/earthkit/workflows/utility.py
src/earthkit/workflows/visualise.py
src/earthkit/workflows/backends/__init__.py
src/earthkit/workflows/backends/arrayapi.py
src/earthkit/workflows/backends/earthkit.py
src/earthkit/workflows/backends/xarray.py
src/earthkit/workflows/graph/__init__.py
src/earthkit/workflows/graph/copy.py
src/earthkit/workflows/graph/deduplicate.py
src/earthkit/workflows/graph/expand.py
src/earthkit/workflows/graph/export.py
src/earthkit/workflows/graph/fuse.py
src/earthkit/workflows/graph/graph.py
src/earthkit/workflows/graph/graphviz.py
src/earthkit/workflows/graph/networkx.py
src/earthkit/workflows/graph/nodes.py
src/earthkit/workflows/graph/pyvis.py
src/earthkit/workflows/graph/rename.py
src/earthkit/workflows/graph/samplegraphs.py
src/earthkit/workflows/graph/split.py
src/earthkit/workflows/graph/transform.py
src/earthkit/workflows/graph/visit.py
src/earthkit/workflows/plugins/__init__.py
src/earthkit_workflows.egg-info/PKG-INFO
src/earthkit_workflows.egg-info/SOURCES.txt
src/earthkit_workflows.egg-info/dependency_links.txt
src/earthkit_workflows.egg-info/not-zip-safe
src/earthkit_workflows.egg-info/requires.txt
src/earthkit_workflows.egg-info/top_level.txt
tests/__init__.py
tests/cascade/__init__.py
tests/cascade/benchmarks/image_processing.py
tests/cascade/controller/__init__.py
tests/cascade/controller/test_run.py
tests/cascade/executor/test_executor.py
tests/cascade/executor/test_runner.py
tests/cascade/gateway/test_run.py
tests/cascade/low/test_builders.py
tests/cascade/low/test_func.py
tests/cascade/scheduler/__init__.py
tests/cascade/scheduler/test_api.py
tests/cascade/scheduler/test_graph.py
tests/cascade/scheduler/util.py
tests/cascade/shm/test_shm.py
tests/earthkit_workflows/__init__.py
tests/earthkit_workflows/conftest.py
tests/earthkit_workflows/helpers.py
tests/earthkit_workflows/test_decorators.py
tests/earthkit_workflows/test_fluent.py
tests/earthkit_workflows/test_metadata.py
tests/earthkit_workflows/backends/generic_tests.py
tests/earthkit_workflows/backends/test_arrayapi.py
tests/earthkit_workflows/backends/test_custom.py
tests/earthkit_workflows/backends/test_earthkit.py
tests/earthkit_workflows/backends/test_register.py
tests/earthkit_workflows/backends/test_xarray.py
tests/earthkit_workflows/graph/payload_utils.py
tests/earthkit_workflows/graph/test_copy.py
tests/earthkit_workflows/graph/test_deduplicate.py
tests/earthkit_workflows/graph/test_expand.py
tests/earthkit_workflows/graph/test_fuse.py
tests/earthkit_workflows/graph/test_graph.py
tests/earthkit_workflows/graph/test_rename.py
tests/earthkit_workflows/graph/test_serialise.py
tests/earthkit_workflows/graph/test_split.py
tests/earthkit_workflows/graph/test_transform.py
tests/earthkit_workflows/graph/test_visit.py