A framework to build and run data pipelines and workflows.
Project description
NoETL
NoETL is an automation framework for orchestrating APIs, databases, and scripts using a declarative Playbook DSL.
Execution is standardized around an MCP-style tool model: consistent tool contracts, structured input/output, and a predictable lifecycle. From an MCP perspective, tools include API endpoints, database operations, and scripts/utilities NoETL orchestrates and optimizes them via playbooks.
With NoETL Gateway, playbooks can be deployed as a distributed backend: developers ship business logic as playbooks, and UIs/clients call stable endpoints without deploying dedicated microservices for each workflow.
Documentation
https://noetl.dev — user-facing site.
NoETL wiki — operator and
developer reference. Pages mirror the code tree under noetl/noetl.
Async batch acceptance and recovery references (on the wiki):
- Batch Events API —
POST /api/events/batchasync acceptance flow - Recovery: Auto-Resume — readiness-gated parent-execution restart at startup
- Command Reaper — runtime re-publish for orphaned / stranded commands
Distributed runtime components
Reference docs for the event-sourced, projection-backed runtime
(implements v2 distributed-runtime spec phases 0–2; spec lives in
noetl/docs at docs/features/noetl_distributed_runtime_spec.md):
- Event Store —
durable append-only event log (port + Postgres adapter),
EventRecordenvelope, optimistic concurrency viaexpected_version. - Projection Store — version-monotonic projection + snapshot store (port + Postgres adapter), query interface for replay state.
- Outbox — transactional
outbox publisher (
python -m noetl.outbox) that drainsnoetl.outboxto NATS with at-least-once retry/backoff. - Projector —
out-of-process projection worker (
python -m noetl.projector), durable NATS pull consumer, shard-stable, Prometheus metrics, replay-state folding shared with the in-process replay API.
EHDB Integration Contract
EHDB integration is disabled by default in this repository. The first NoETL-side surface is a feature-flagged contract only; it validates the execution-model boundary before any storage cutover exists.
Environment flags:
NOETL_EHDB_ENABLED=trueturns on contract validation.NOETL_EHDB_MODE=local_referenceselects the local reference readiness mode.NOETL_EHDB_CLIENT_ROLE=worker|playbookdeclares the caller role.NOETL_EHDB_LOCAL_REFERENCE_LOG=/path/to/ehdb.jsonlprovides the explicit local event-log path for the reference mode.NOETL_EHDB_HELPER_BIN=/path/to/helperis required only when a worker/playbook asks NoETL to build a local-reference helper invocation plan.
Gateway/server roles are rejected when EHDB is enabled. Gateway remains the gatekeeper; workers remain atomic compute; playbooks remain ephemeral blueprints; shared cache remains a state vehicle; the event log remains the source of truth. This contract does not connect to EHDB, replace PostgreSQL/NATS/object stores, add a gateway route, or start a persistent per-tenant process.
noetl.core.ehdb_adapter.ehdb_adapter_from_env builds the disabled-by-
default adapter descriptor behind that contract. Disabled configuration
returns None; worker/playbook local_reference configuration returns
a LocalReferenceEhdbAdapter carrying the explicit event-log path and
exportable runtime environment for future EHDB helper calls. The adapter
does not open logs, connect to EHDB, or perform storage operations.
noetl.core.ehdb_adapter.ehdb_helper_invocation_from_env builds the
next planning surface for those helper calls. Disabled configuration
returns None; enabled worker/playbook configuration requires an
explicit helper executable and returns deterministic argv plus EHDB
runtime env that can be merged into a subprocess environment. The
invocation plan is immutable and side-effect-free; it does not execute a
subprocess, import EHDB, open logs, connect to storage, or add
gateway/server data paths.
Repository model (ai-meta driven)
NoETL development is now coordinated through the ai-meta repository:
- Orchestration/meta: https://github.com/noetl/ai-meta
- Server: https://github.com/noetl/server
- Worker: https://github.com/noetl/worker
- Gateway: https://github.com/noetl/gateway
- CLI: https://github.com/noetl/cli
- Tools: https://github.com/noetl/tools
- End-to-end fixtures: https://github.com/noetl/e2e
- Ops/automation: https://github.com/noetl/ops
- Docs: https://github.com/noetl/docs
ai-meta tracks all component repositories as Git submodules and is the primary place to
coordinate cross-repo changes, pointer bumps, and release choreography.
End-to-end integration playbooks, fixture payloads, local credential templates, notebooks,
and Gateway UI test fixtures live in noetl/e2e.
Distribution channels
- PyPI
noetl(Python): https://pypi.org/project/noetl/
- Rust components
- CLI repo: https://github.com/noetl/cli
- Gateway repo: https://github.com/noetl/gateway
- Server repo: https://github.com/noetl/server
- Worker repo: https://github.com/noetl/worker
- Tools repo: https://github.com/noetl/tools
- APT (Debian/Ubuntu)
- Homebrew
License
Dual License — see LICENSE for details.
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Filter files by name, interpreter, ABI, and platform.
If you're not sure about the file name format, learn more about wheel file names.
Copy a direct link to the current filters
File details
Details for the file noetl-4.15.0.tar.gz.
File metadata
- Download URL: noetl-4.15.0.tar.gz
- Upload date:
- Size: 883.4 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
- Uploaded via: uv/0.9.30 {"installer":{"name":"uv","version":"0.9.30","subcommand":["publish"]},"python":null,"implementation":{"name":null,"version":null},"distro":{"name":"Ubuntu","version":"24.04","id":"noble","libc":null},"system":{"name":null,"release":null},"cpu":null,"openssl_version":null,"setuptools_version":null,"rustc_version":null,"ci":true}
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
64b6ffa30ade77775d2aac8cab4869197bb310fd94793d7040cc8a7435f33bc8
|
|
| MD5 |
0db42ffccd371124533fe04c66be2a1a
|
|
| BLAKE2b-256 |
7e230089b198935ee6d9ddd60c4d677fbba737cd0ac2d8722b986d79d36f4cb0
|
File details
Details for the file noetl-4.15.0-py3-none-any.whl.
File metadata
- Download URL: noetl-4.15.0-py3-none-any.whl
- Upload date:
- Size: 984.5 kB
- Tags: Python 3
- Uploaded using Trusted Publishing? No
- Uploaded via: uv/0.9.30 {"installer":{"name":"uv","version":"0.9.30","subcommand":["publish"]},"python":null,"implementation":{"name":null,"version":null},"distro":{"name":"Ubuntu","version":"24.04","id":"noble","libc":null},"system":{"name":null,"release":null},"cpu":null,"openssl_version":null,"setuptools_version":null,"rustc_version":null,"ci":true}
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
8f0c8c1e9d3c7dbfeba4702a1e242bfa09d5d6f1d805ba034005bc374755e151
|
|
| MD5 |
bab6f40b79292afdfd519e9f8db99476
|
|
| BLAKE2b-256 |
6d1521ceb58d363c52b4f738975e71f49173446be698715a671dd2dbf55ed8e8
|
