Architecture map¶
Beampipe is the durable control plane between archive metadata, project policy, workers, schedulers, and DALiuGE. It decides and records what should happen; external systems perform the scientific work.
Explore the boundary¶
Archive facts and project policy enter separately
CASDA supplies metadata. Versioned project YAML supplies queries, transforms, manifest shape, graph patches, and automation limits. An execution pins the configuration revision it used.
PostgreSQL carries control-plane truth
The API records operator intent. The ledger, jobs, claims, artifacts, profile snapshots, and provenance make that intent recoverable across API and worker restarts.
Workers perform bounded side effects
Workers claim compatible jobs with leases and fencing tokens. Heartbeats, labels, pool requirements, concurrency limits, and dead-letter state make horizontal operation explicit.
Schedulers and DALiuGE remain external authorities
Beampipe stores their identifiers and observed states independently. A scheduler allocation, DALiuGE session, and verified output are related facts, not interchangeable definitions of success.
Follow a concept¶
The invariant¶
Every external action must be tied to persisted intent, deterministic identity, an immutable profile/config snapshot, and enough provenance to reconcile after interruption.