.flake8
.gitignore
.pre-commit-config.yaml
.python_version
AGENTS.md
LICENSE
README.md
cascade.png
justfile
pyproject.toml
research-and-development.md
roadmap.md
setup.py
uv.lock
.github/workflows/cd-pypi.yml
.github/workflows/label-public-prs.yml
.github/workflows/macos-test.yml
.github/workflows/test-pypi.yml
benchmarks/README.md
benchmarks/scenario-shm_throughput.py
benchmarks/scheduling/sat_experiments.py
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
docs/tutorials/cascade-job_building/readme.md
docs/tutorials/cascade-job_building/t00_execute.py
docs/tutorials/cascade-job_building/t00_generate.py
docs/tutorials/cascade-job_building/t01_low.py
docs/tutorials/cascade-job_building/t02_builders.py
docs/tutorials/cascade-job_building/t03_custom.py
docs/usage/qubed.rst
integration_tests/base.py
integration_tests/harness.py
integration_tests/job_runnerRestarts.py
integration_tests/benchmarks_old/__init__.py
integration_tests/benchmarks_old/anemoi.py
integration_tests/benchmarks_old/dask.py
integration_tests/benchmarks_old/dist.py
integration_tests/benchmarks_old/generators.py
integration_tests/benchmarks_old/job1.py
integration_tests/benchmarks_old/matmul.py
integration_tests/benchmarks_old/plotting.py
integration_tests/benchmarks_old/reporting.py
integration_tests/benchmarks_old/util.py
integration_tests/runtime/__init__.py
scripts/example_config.sh
scripts/launch_slurm.sh
scripts/slurm_entrypoint.sh
src/cascade/__init__.py
src/cascade/main.py
src/cascade/py.typed
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/checkpoints.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/gateway/spawning.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/checkpoints.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/_qubed.py
src/earthkit/workflows/_version.py
src/earthkit/workflows/adapters.py
src/earthkit/workflows/compilers.py
src/earthkit/workflows/decorators.py
src/earthkit/workflows/fluent.py
src/earthkit/workflows/mark.py
src/earthkit/workflows/nodetree.py
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/__init__.py
tests/cascade/executor/test_callables.py
tests/cascade/executor/test_checkpoints.py
tests/cascade/executor/test_executor.py
tests/cascade/executor/test_packages.py
tests/cascade/executor/test_runner.py
tests/cascade/executor/util.py
tests/cascade/gateway/test_run.py
tests/cascade/low/test_builders.py
tests/cascade/low/test_core.py
tests/cascade/low/test_func.py
tests/cascade/scheduler/__init__.py
tests/cascade/scheduler/test_api.py
tests/cascade/scheduler/test_checkpoints.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/test_qubed_expansion.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