e0918b88 Andy McCall 1 month ago
1
# OxygenFlow M0: first pipeline on Earth
2
3
4
5
| ** Status** | Plan, 2026-09-28 |
6
| ** Implements** | a subset of ` docs/spec.md` (Draft 0.1) |
7
| ** Goal** | A push to a repository on OxygenHub (Earth) runs ` .flow/pipeline.kdl` in Firecracker microVMs, and the hub shows the run as a graph of jobs with live status and logs. |
8
9
M0 is the smallest slice that exercises the real architecture: a typed
10
pipeline compiled to a canonical form, host-side execution in the default
11
isolation tier, receipts computed by the host, and results reported to the
12
hub as checks. Everything M0 leaves out is listed at the end.
13
14
## 1. Pipeline subset
15
16
The file is ` .flow/pipeline.kdl` in the state being built (KDL 2.0). M0
17
accepts:
18
19
``` kdl
20
schema-version 1
21
22
sandbox "alpine" {
23
runtime "microvm" // "microvm" (default) | "syscall"; "wasm" is refused in M0
24
rootfs "cas://blob/<64 hex>" // BLAKE3 of an ext4 image the runner holds
25
memory-limit "1GiB" // KiB, MiB, GiB
26
cpu-limit 2
eb5c4db6 Andy McCall 1 month ago ↶
27
network "isolated" // "isolated" or "loopback" in M0
a72abeee Andy McCall 1 month ago ↶
28
env { PATH "/opt/tool/bin:/usr/bin:/bin" } // every job's starting environment
e0918b88 Andy McCall 1 month ago
29
}
30
31
job "lint" {
32
sandbox "alpine"
33
scope "src/**" "README.md" // recorded; the job runs on every push in M0
34
env { LANG "C.UTF-8" }
35
exec "grep" "-rn" "TODO" "src"
36
}
37
38
job "test" {
39
sandbox "alpine"
40
depends-on "lint"
41
exec "sh" "-eu" "test.sh"
42
}
43
```
44
45
Rules, all checked by ` flow check` and again by the hub before anything
46
runs (spec §2.2 I2, §3.2):
47
48
- Unknown nodes, arguments or properties are errors, with the line.
49
- Every string stays a string; ` cpu-limit` is an integer from 1 to 16;
50
` memory-limit` parses to 64 MiB to 16 GiB.
51
- A job names a declared sandbox, has a non-empty ` exec` of literal
52
strings, and ` depends-on` only declared jobs; the graph has no cycle.
53
- Names are 1 to 64 characters from ` [A-Za-z0-9._-]` .
54
- ` exec` becomes ` argv` unchanged: metacharacters are bytes (spec §10.1).
55
A job that wants a shell names one, as ` sh` above; nothing adds one.
a67b97e9 Andy McCall 1 month ago ↶
56
- ` publish` and ` secret` are recognised and refused with "not in M0", so
57
a pipeline written for the full spec fails clearly.
58
- ` output { artifact "oxy" { path "/src/target/release/oxy" } }` declares
59
up to 16 ** artifacts** (spec §5.2). The path is clean, absolute, under
60
` /src` , and not on a tmpfs mount, which is gone when the job ends. After
61
a job passes, the runner reads each artifact from the job's disks with
62
` debugfs` : the workspace, or the ` ephemeral://disk` mount holding it. An
63
artifact is at most 512 MiB. The runner uploads each one with
64
` POST /api/v1/flow/jobs/{id}/artifacts/{name}` (raw bytes). The hub keeps
65
it as a blob of the repository, and the receipt's ` outputs` name those
66
blobs in artifact order. A declared artifact that cannot be kept fails
67
the job, and the job gets no receipt.
fc10d9e8 Andy McCall 1 month ago ↶
68
- ` mount` is accepted for ** ephemeral scratch** only (up to 4 per job):
69
` mount { source "ephemeral://disk"; target "/src/target"; size "8GiB" }` .
70
` ephemeral://tmpfs` is memory in the guest and counts against its
71
memory-limit; ` ephemeral://disk` is a fresh sparse ext4 disk on the
72
runner, attached after the workspace, for build trees larger than
73
memory. The target is a clean absolute path strictly under ` /src` or
74
` /tmp` , mounts may not nest, sizes run from 16 MiB to 64 GiB, and any
75
other source (` oxy://workspace` and the rest) or setting (` readonly` ,
76
` include` ) is refused as not in M0. Both are empty when the job starts
77
and deleted when it ends, so nothing passes between jobs. Mounts are
78
part of the job's canonical form (field 6, present only when a job has
79
mounts, so pipelines without them keep their hashes) and of the
80
receipt's environment.
a72abeee Andy McCall 1 month ago ↶
81
82
- A sandbox's ` env` is where each of its jobs' environments starts; a
83
job's own ` env` overrides it name by name. It is part of the sandbox's
84
canonical form (field 6, present only when set). Below both is the
85
image's own environment: ` flow rootfs import --env NAME=value`
86
(repeatable) writes ` /etc/flow/env` into the image, for what a
87
Dockerfile's ` ENV` sets and ` docker export` loses, such as a toolchain's
88
` PATH` . It is part of the image, so of its hash. Under all three are
89
` PATH` (the usual directories) and ` HOME=/tmp` .
e0918b88 Andy McCall 1 month ago
90
91
The pipeline compiles to a canonical CBOR job graph (sorted keys, sandboxes
92
and jobs in name order). Its BLAKE3 is the ` pipeline_hash` used in receipts
93
and shown by the hub.
94
95
## 2. Tier 2: Firecracker (default)
96
97
Per job the runner:
98
99
1. Verifies the rootfs image: ` BLAKE3(file)` must equal the pinned hash.
100
Images live in ` $FLOW_HOME/cas/<hash>.ext4` ; an unknown hash fails the
101
job ("rootfs not on this runner").
102
2. Materializes the state at its heads with ` oxy` into a scratch
103
directory (a clone at the state), removes ` .oxy` , and builds a
104
workspace image with ` mkfs.ext4 -d` sized to the tree plus 512 MiB.
105
3. Boots Firecracker with no network device (so ` isolated` holds by
eb5c4db6 Andy McCall 1 month ago ↶
106
construction; ` loopback` only brings up the guest's ` lo` , so tests can
107
serve and connect on 127.0.0.1 while nothing leaves the guest), ` vcpu_count` and ` mem_size_mib` from the sandbox, the
e0918b88 Andy McCall 1 month ago
108
pinned guest kernel, the rootfs as a ** read-only** ` vda` , the
109
workspace as a read-write ` vdb` , and an initramfs holding ` flow-init` .
110
4. ` flow-init` (a static binary, PID 1 in the guest) mounts ` /proc` ,
111
` /sys` , ` /dev` , the rootfs at ` /newroot` read-only, ` vdb` at
fc10d9e8 Andy McCall 1 month ago ↶
112
` /newroot/src` , and tmpfs at ` /newroot/tmp` and ` /newroot/run` , then the
113
job's scratch mounts (creating their mount points, owned by the job's
114
user); it
eb5c4db6 Andy McCall 1 month ago ↶
115
switches root, then runs ` argv` (its program found in the guest's ` PATH` by
116
` flow-init` itself) with exactly the job's ` env` (plus
e0918b88 Andy McCall 1 month ago
117
` PATH` , ` HOME=/tmp` ) in ` /src` as uid 1000, with a job timeout.
c4285535 Andy McCall 1 month ago ↶
118
` /dev` gets the links devtmpfs lacks, ` fd` , ` stdin` , ` stdout` and
119
` stderr` into ` /proc/self/fd` , so shell process substitution works. A job
120
is told what it builds: ` FLOW_REPO` , ` FLOW_STATE` (the hub's state hash),
121
` FLOW_HEADS` (full hashes joined with ` +` ), ` FLOW_BOOKMARK` , ` FLOW_RUN`
122
(the run's number in its repository) and ` FLOW_JOB` ; ` flow run` sets
123
` FLOW_JOB` and ` FLOW_RUN=local` . A variable the pipeline sets keeps its
124
value. They are part of the job's environment, so of its receipt.
e0918b88 Andy McCall 1 month ago
125
5. ` flow-init` frames the child's output on the serial console as
126
` \x1eO <line>` (stdout) and ` \x1eE <line>` (stderr), then
127
` \x1eX <code>` , and powers off. The kernel runs ` quiet` so the host sees
128
only frames; anything else is kept as ` console` records.
129
6. The host reads frames, streams them as log records, and kills the VM
130
at the timeout (the guest cannot extend it). Scratch files are deleted
131
afterwards. Guest memory is released with the process.
132
133
The guest kernel, ` flow-init` and Firecracker itself are pinned by BLAKE3
134
in the runner's configuration; their hashes and the rootfs hash make the
135
receipt's ` environment` together with ` argv` and ` env` .
136
137
## 3. Tier 1: syscall sandbox
138
139
` runtime "syscall"` : a child in new user, mount, PID, network, IPC and
140
UTS namespaces (no interfaces but loopback), the rootfs image's tree
141
(unpacked once per hash, read-only) as ` /` , the workspace directory at
142
` /src` , tmpfs at ` /tmp` ; Landlock limits writes to ` /src` and ` /tmp` ; a
143
seccomp filter refuses ` socket` for anything but ` AF_UNIX` , plus
144
` ptrace` , ` mount` , ` bpf` , ` perf_event_open` , ` keyctl` and module calls;
145
` cpu-limit` and ` memory-limit` apply through a cgroup v2 scope when the
146
runner has a delegated cgroup, and the job fails to start otherwise
147
rather than run unbounded. Same frames and receipts as tier 2. Done after
148
tier 2 works on Earth.
149
150
## 4. Receipts
151
152
Every finished job gets a receipt (spec §6.1): ` job_name` ,
153
` pipeline_hash` , ` scope_tree_hash` (BLAKE3 over the sorted
154
` (path, content hash)` of the files ` scope` matches; the whole tree when
155
there is no scope), ` inputs` (empty in M0), ` environment` , ` outputs`
156
(empty), ` exit_code` , ` duration_ms` . It is encoded as canonical CBOR and
47c1d64d Andy McCall 1 month ago ↶
157
hashed as ` BLAKE3("oxy1 receipt " || len || 0x00 || body)` , the ` receipt`
158
object of the Oxygen spec (§14.6).
159
f98a8f78 Andy McCall 1 month ago ↶
160
** Registering a runner.**
161
- ** Token:** a hub administrator creates a one-time registration token on Admin → Runners.
162
- ** Registering:** ` flow runner register https://hub --token … [--name N] [--ca PATH] [--label L]…` sends the runner's signing identity, architecture, OS, version and labels (` POST /api/v1/flow/runners/register` ). It gets back the runner's own credential and writes hub, credential, name, CA and labels to ` runner.toml` (owner-only). That file stands in for a ` [runner]` section ` flow.toml` lacks, and ` flow runner` then starts from it.
163
- ** Key:** registration binds the key; the hub accepts receipts from that runner signed by no other.
164
- ** Claims:** every claim carries the runner's description (` info` : architecture, OS, version, labels, capacity) for the Runners page.
165
- ** Old configuration:** runners configured with a ` hub.toml` token still work. Their key is bound on their first signed receipt.
166
47c1d64d Andy McCall 1 month ago ↶
167
** Signed receipts.** A runner keeps a composite key in its home
168
(` runner.key` , owner-only, and ` runner.identity` ), made on first start and
169
named after the runner. After each job it binds the receipt to the state of
170
the heads it fetched (computed by the runner, not taken from the claim) and
171
to the run's URL, signs that attestation, and sends the signed receipt with
172
` finish` as ` signed_receipt` (hex). The hub checks it and keeps it in the
173
repository; anyone can then check it with ` oxy receipt verify` . Cache reuse
174
(§6.2) follows.
e0918b88 Andy McCall 1 month ago
175
176
## 5. Hub side (OxygenHub)
177
178
- Configuration: ` [flow] runner_tokens = [...]` and ` repos = ["owner/*"]` ,
179
the repositories whose pushes may start runs. No proposals trigger runs
180
in M0, so code from people without write access never runs.
181
- On a push that moves a bookmark of an allowed repository, the hub reads
182
` .flow/pipeline.kdl` from the new state, validates it with ` flow-core` ,
183
and records a ** run** (repository, bookmark, state address, pipeline
184
hash, pusher) with one ** job** per pipeline job. An invalid pipeline
185
records a failed run with the error and its line.
186
- Runner API, bearer runner token:
187
- ` POST /api/v1/flow/claim` → the oldest queued job whose dependencies
188
passed, with its run's state heads, repository clone URL, the job's
189
compiled form and its sandbox, and a ** job token** : read access to that
190
repository only, valid until the job finishes or 2 hours pass. ` 204`
191
when there is nothing.
192
- ` POST /api/v1/flow/jobs/{id}/log` appends records ` {t, stream, text}` .
193
- ` POST /api/v1/flow/jobs/{id}/finish` with the exit code, duration and
194
receipt; a job whose dependency failed becomes ` skipped` .
195
- Each job is also a check named ` flow/<job>` on the state (hub spec §13),
196
so proposals, the status bar in VS Code and required checks see it.
197
- Pages: a ** Flow** tab with runs (status, bookmark, state, pusher,
198
duration); a run page with the job graph drawn as SVG (columns by
199
dependency depth, status by colour and glyph), each job's log folded
200
by default and the failed one open, refreshed while the run is live.
201
202
## 6. Earth
203
204
Under ` /home/claude/flow` : ` bin/firecracker` (release binary, pinned),
205
` kernel/vmlinux` (pinned), ` cas/` (rootfs images), ` work/` (scratch), and
206
` runner.toml` . ` flow runner` runs as the ` flow-runner` systemd service
207
under the ` claude` user (member of ` kvm` ), polling the hub at
208
` https://earth.andymccall.xyz:7343` .
209
210
## 7. Not in M0
211
212
WASM tier; FastCDC-backed rootfs and ` casfs` mounts (M0 copies the tree
a67b97e9 Andy McCall 1 month ago ↶
213
into an image); mounts other than ephemeral scratch; artifacts as inputs of later jobs; receipt reuse; provenance
214
attestations; policy gates; secrets; proposal
e0918b88 Andy McCall 1 month ago
215
runs; scope-based skipping; re-run and cancel from the hub.