diff --git a/.github/workflows/ci.yml b/.github/workflows/ci.yml
index e5e51f0..87979c2 100644
--- a/.github/workflows/ci.yml
+++ b/.github/workflows/ci.yml
@@ -118,6 +118,15 @@ jobs:
       - name: Tests
         run: make check-tests PYTEST=pytest
 
+      # `make test-e2e` runs its scripts with `uv run --locked`, and Renovate's
+      # pep723 manager can bump a script's pin but has no step that rewrites its
+      # lock, so a pin and lock that disagree are caught here, not mid-suite.
+      - name: Install uv
+        run: pipx install --python "${{ steps.python.outputs.python-path }}" "uv==$(make -s print-uv-version)"
+
+      - name: Script locks
+        run: make check-locks LOCK_UV=uv
+
   # The slim and single profiles are projections of the Kubernetes tiers of the
   # same name, so they go stale when those tiers move and nothing here notices.
   # dfe-infra is PRIVATE, so the checkout reads it with a short-lived GitHub App
diff --git a/Makefile b/Makefile
index 353da34..60e9102 100644
--- a/Makefile
+++ b/Makefile
@@ -52,7 +52,7 @@ endif
 # any more (both sweep every profile), and requiring a resolvable profile to STOP
 # a stack is the same lockout the compose secret comments argue against -- set
 # DFE_PROFILE to something that does not exist and you could not tear down.
-BOOTSTRAP_GOALS := init env-files creds dev-posture help login stack dial modes down clean limits check check-compose check-hardfail check-dockerfile check-docs check-proxy check-python check-tests
+BOOTSTRAP_GOALS := init env-files creds dev-posture help login stack dial modes down clean limits check check-compose check-hardfail check-dockerfile check-docs check-locks check-proxy check-python check-tests
 
 # Resolve the active profile only when a goal actually needs the compose stack
 ifneq (,$(filter-out $(BOOTSTRAP_GOALS),$(or $(MAKECMDGOALS),help)))
@@ -536,7 +536,7 @@ infra: .env storage-dirs ## Start infrastructure services
 # ---------------------------------------------------------------------------
 
 .PHONY: check
-check: check-compose check-hardfail check-dockerfile check-docs check-proxy check-python check-tests ## Run every static check CI runs
+check: check-compose check-hardfail check-dockerfile check-docs check-proxy check-python check-tests check-locks ## Run every static check CI runs
 
 .PHONY: limits
 limits: ## Show the resource limits and totals, computed from the resolved config
@@ -571,6 +571,20 @@ print-pytest-version:
 check-tests: ## Run the helper-script unit tests (scripts/tests)
 	$(PYTEST) -q scripts/tests
 
+# Each inline-metadata script runs with `uv run --locked`, and Renovate's pep723 manager rewrites a pin but never its lock, so this fails a pin and lock that disagree.
+# Pinned and installed in CI the way RUFF is (LOCK_UV=uv).
+UV_VERSION := 0.13.0
+LOCK_UV ?= uvx uv@$(UV_VERSION)
+
+.PHONY: print-uv-version
+print-uv-version:
+	@echo $(UV_VERSION)
+
+.PHONY: check-locks
+check-locks: ## Assert each inline-metadata script's lock matches its pins (relock with `uv lock --script <script>`)
+	$(LOCK_UV) lock --check --script scripts/test_e2e.py
+	$(LOCK_UV) lock --check --script scripts/test_flows.py
+
 # `slim` and `single` are projections of the Kubernetes tiers of the same name,
 # so both targets need DFE_INFRA_DIR pointed at a dfe-infra checkout. Unset,
 # check-profiles reports SKIPPED rather than passing: it cannot read the master.
@@ -646,19 +660,22 @@ check-proxy: ## Validate the Envoy proxy configs, plain and TLS, on the pinned E
 # The suite starts each test's stack from its own -f list. Under console TLS that stack needs the TLS fragment and the network it pins, so the suite takes every fragment `make ci` chains, the exposure opt-outs and container logs included; with TLS off it keeps its own list. DFE_E2E_COMPOSE_FILES follows either way, and the suite skips the empty entries the colons leave.
 E2E_COMPOSE_FILES = $(if $(filter true,$(strip $(DFE_PROXY_TLS))),$(UI_CHAIN)):$(strip $(DFE_E2E_COMPOSE_FILES))
 
+# The scripts that import packages beyond the standard library declare them inline (PEP 723) and lock them beside the script, so uv installs exactly the hashed set and a host needs only uv.
+UV ?= uv
+
 .PHONY: test-e2e
 test-e2e: ## End-to-end test executor (pass test names via E2E_TESTS)
-	@DFE_E2E_COMPOSE_FILES='$(E2E_COMPOSE_FILES)' python3 ./scripts/test_e2e.py $(E2E_TESTS)
+	@DFE_E2E_COMPOSE_FILES='$(E2E_COMPOSE_FILES)' $(UV) run --locked --script ./scripts/test_e2e.py $(E2E_TESTS)
 
 # Opt-in, never part of test-e2e: each test stops a backing service or a DFE app
 # under load.
 .PHONY: test-resilience
 test-resilience: ## Outage tests: stop a service under load and prove the rest survives (pass test names via E2E_TESTS)
-	@DFE_E2E_COMPOSE_FILES='$(E2E_COMPOSE_FILES)' python3 ./scripts/test_e2e.py --outages $(E2E_TESTS)
+	@DFE_E2E_COMPOSE_FILES='$(E2E_COMPOSE_FILES)' $(UV) run --locked --script ./scripts/test_e2e.py --outages $(E2E_TESTS)
 
 .PHONY: test-flows
 test-flows: ## Flow shapes against a running stack (needs DFE_ENGINE_REPO; FLOW_ARGS passes flags)
-	@python3 ./scripts/test_flows.py $(FLOW_ARGS)
+	@$(UV) run --locked --script ./scripts/test_flows.py $(FLOW_ARGS)
 
 # The post-deploy source test: add a source through the console and prove every
 # hop. The runner is dfe-infra's, the same one `dfe-ops acceptance --suite
diff --git a/docs/developing.md b/docs/developing.md
index 4b6d4e8..9b66640 100644
--- a/docs/developing.md
+++ b/docs/developing.md
@@ -27,7 +27,7 @@ exist, and how a profile decides which of them run.
 |---|---|
 | Docker and Docker Compose v2 | everything |
 | Python 3 | the helper scripts under `scripts/` |
-| PyYAML | `make test-e2e` and `make test-resilience` only (`pip install pyyaml`, or `uv run --with pyyaml`) |
+| uv | `make test-e2e`, `make test-resilience` and `make test-flows` only. It installs the PyYAML and Playwright those scripts declare inline, hash-checked against the `<script>.lock` beside each |
 | ruff | `make check-python` only |
 | pytest | `make check-tests` only (`uvx` fetches the pin if you have it) |
 | git credentials for the hyperi-io repos (or `DFE_SRC_ROOT` checkouts) | `make dev` |
@@ -324,6 +324,10 @@ An archiver that subscribes to the test's landing topic and archives to a
 since a baseline taken before the send. The archive volume outlives the stack, so
 files from an earlier run never count.
 
+The data file goes to the ingest edge 16 requests at a time. The receiver answers each request once the loader has flushed it, so one at a time costs a flush per event.
+
+The suite stops whatever stack the project is running, so it reads the project first. On every way out, a failure or a SIGTERM included, it starts each service that was running or had run to completion again, from the compose files it was started from. A last verdict fails if one comes back on a different config hash. Run it as the user that started the stack: `make` writes that user's GID into the engine's config, and under console TLS its UID and GID into both proxies'.
+
 Under [console TLS](configuration.md#console-tls-opt-in) each test's stack chains the fragments `make ci` does, the exposure opt-outs and container logs included. The console checks go to `https://<DFE_EXTERNAL_ORIGIN host>:<DFE_UI_PORT>` and verify its certificate by chain and name, against `DFE_PROXY_CA_BUNDLE` when a private CA signed it. A certificate that does not verify fails the check with the variable to change.
 
 Two things about the runner worth knowing before you debug it:
@@ -355,7 +359,7 @@ The `core` footprint starts `dfe-hunt-runner`, as `make dev` does. On a profile
 ### Search to rule to hunt -- the console path
 
 ```bash
-uv run --with pyyaml --with playwright==1.63.0 python3 scripts/test_e2e.py search-rule-hunt
+make test-e2e E2E_TESTS=search-rule-hunt
 ```
 
 A `detection:` block carrying `from_search` makes its rule the way an analyst does, in a browser. It adds HyperDX to the stack, signs in to the console as the stack's admin and opens Observe search on `main`. The search bar gets the block's `search`, held to the run's marker, and the side panel picks its `filter`. Then Create Rule, and the rule page it opens.
@@ -364,7 +368,7 @@ The stored rule has to scan `dfe.main` with no SQL errors and a WHERE that carri
 
 The side panel only offers values rows already hold, so both event sets are sent once before the search. The hunt's first window can reach those rows, so their near misses are judged too, and their matches are not.
 
-The console holds every page behind its setup wizard, so the test first makes the `e2e` organisation and one user of the deployment's own, as the wizard would. It needs an interpreter with Playwright and Google Chrome (`playwright install chrome` where Chrome is absent). `DFE_E2E_HEADED=1` shows the browser, and `DFE_E2E_SHOTS_DIR` keeps the step screenshots, which otherwise go to a new temporary directory named in the log.
+The console holds every page behind its setup wizard, so the test first makes the `e2e` organisation and one user of the deployment's own, as the wizard would. uv installs Playwright from the script's inline metadata, and the test drives Google Chrome (`uvx playwright install chrome` where it is absent). `DFE_E2E_HEADED=1` shows the browser, and `DFE_E2E_SHOTS_DIR` keeps the step screenshots, which otherwise go to a new temporary directory named in the log.
 
 Under console TLS the suite first verifies the console certificate itself, then pins Chrome to that certificate's public key, because Chrome takes no CA bundle.
 
@@ -431,6 +435,7 @@ that is a finding about the console rather than about the pipeline.
 | `make check-proxy` | `envoy --mode validate` on both proxy configs and their console TLS variants, on the Envoy the stack pins |
 | `make check-python` | `ruff check` and `ruff format --check` on `scripts/` |
 | `make check-tests` | `pytest scripts/tests` -- unit tests over the credential helpers |
+| `make check-locks` | `uv lock --check` on each script that declares packages inline, so a pin moved without `uv lock --script <script>` fails here rather than mid-suite |
 
 `check-compose` is hermetic: it reads the mandatory `${VAR:?}` keys out of the
 compose file and substitutes placeholders, so it needs neither the stack SSoT nor
@@ -443,9 +448,9 @@ for why a lower ceiling takes health endpoints dark.
 external URLs and does not check `#anchors`, so a live file with a stale anchor
 still passes.
 
-`check-dockerfile` pulls the pinned hadolint image and `check-tests` resolves the
-pinned pytest through `uvx`, so both want a network the first time. The rest need
-none.
+`check-dockerfile` pulls the pinned hadolint image, `check-tests` resolves the
+pinned pytest through `uvx` and `check-locks` the pinned uv, so those want a
+network the first time. The rest need none.
 
 `check-proxy` pulls the pinned Envoy image the same way and mints a throwaway P-384 certificate with the host's `openssl` for the TLS variants.
 
diff --git a/docs/observability.md b/docs/observability.md
index 61595f3..d1afdda 100644
--- a/docs/observability.md
+++ b/docs/observability.md
@@ -209,6 +209,8 @@ Node metrics are still not collected.
   through the API reaches the running receiver, and a record matching its rule
   lands in a table of its own.
 
+Once every claim has run, the three ingest rows are deleted: a lightweight `DELETE`, or a mutation (`ALTER TABLE ... DELETE`) on a table whose projections refuse one. A delete that does not finish within 60s is reported, never failed.
+
 The freshness window is what makes the second claim mean "streaming now" rather
 than "streamed once". The first two are the pair the Kubernetes bootstrap smoke
 asserts as CORE 1 and CORE 2.
diff --git a/docs/troubleshooting.md b/docs/troubleshooting.md
index e0af306..361e82e 100644
--- a/docs/troubleshooting.md
+++ b/docs/troubleshooting.md
@@ -367,16 +367,17 @@ nothing set and requiring that it fails for the right reason. A green run proves
 the stack refuses to resolve with nothing set; it does not prove every single
 image is pinned, because compose aborts on the first missing variable.
 
-### `PyYAML is required and not installed`
+### `PyYAML is not installed in this interpreter`
 
-PyYAML is the e2e harness's only third-party dependency, and it is not in the
-standard library:
+The e2e harness declares PyYAML and Playwright inline (PEP 723), locked in `scripts/test_e2e.py.lock`, and `make test-e2e` runs it through uv, which installs them. A bare `python3 scripts/test_e2e.py` skips that step:
 
 ```bash
-pip install pyyaml
-uv run --with pyyaml python3 scripts/test_e2e.py   # or run it this way
+make test-e2e
+uv run --locked --script scripts/test_e2e.py   # the same, without make
 ```
 
+`The lockfile at uv.lock needs to be updated` from either means a pin in the script moved without its lock: run `uv lock --script scripts/test_e2e.py` and commit both.
+
 The power-on self test (`scripts/post.py`) has no such dependency -- it is
 stdlib-only and works on a bare machine.
 
diff --git a/scripts/_pipeline.py b/scripts/_pipeline.py
index 994ea87..fbf384b 100644
--- a/scripts/_pipeline.py
+++ b/scripts/_pipeline.py
@@ -26,6 +26,8 @@
 import re
 import time
 import typing
+from concurrent.futures import ThreadPoolExecutor
+from http.client import HTTPException
 from urllib.error import URLError
 from urllib.request import Request, urlopen
 
@@ -169,6 +171,26 @@ def http_post(
     )[0]
 
 
+def post_all(
+    url: str, bodies: typing.Sequence[str], *, workers: int, timeout: int = 10
+) -> list[int]:
+    """POST every body from `workers` concurrent senders, returning each status in order.
+
+    The receiver answers once the next hop holds the record, so one request at a
+    time waits out the loader's flush on every event. A request that got no HTTP
+    answer at all reports status 0.
+    """
+
+    def _send(body: str) -> int:
+        try:
+            return http_post(url, body, timeout=timeout)
+        except (HTTPException, OSError):
+            return 0
+
+    with ThreadPoolExecutor(max_workers=max(1, workers)) as pool:
+        return list(pool.map(_send, bodies))
+
+
 def http_delete(url: str, token: str = "", timeout: int = 10) -> int:
     """DELETE a resource and return the HTTP status.
 
@@ -200,6 +222,26 @@ def ch_query(sql: str, *, debug: typing.Callable[[str], None] | None = None) ->
         return ""
 
 
+def ch_execute(sql: str, *, timeout: int = 10) -> tuple[bool, str]:
+    """Run a statement over ClickHouse's HTTP interface, keeping the server's answer.
+
+    Returns (True, body) on success and (False, the error text) otherwise, for a
+    caller that has to act on WHY a statement was refused.
+    """
+    request = Request(clickhouse_url(), data=sql.encode(), method="POST")
+    request.add_header("X-ClickHouse-User", env_or("CLICKHOUSE_USERNAME", "default"))
+    request.add_header("X-ClickHouse-Key", os.environ.get("CLICKHOUSE_PASSWORD", ""))
+    try:
+        with urlopen(request, timeout=timeout) as response:
+            return True, response.read().decode().strip()
+    except URLError as error:
+        if hasattr(error, "read"):
+            return False, error.read().decode(errors="replace").strip()
+        return False, str(error.reason)
+    except OSError as error:
+        return False, str(error)
+
+
 def ch_count(database: str, table: str, *, debug=None) -> int:
     """Return the row count of a table, or 0 if it cannot be read."""
     count = ch_int(f"SELECT count() FROM {database}.{table}", debug=debug)
diff --git a/scripts/_search_rule.py b/scripts/_search_rule.py
index fbfeb11..0556b73 100644
--- a/scripts/_search_rule.py
+++ b/scripts/_search_rule.py
@@ -59,9 +59,9 @@
 # An option in whichever console select is open.
 OPEN_OPTION = ".ant-select-dropdown:not(.ant-select-dropdown-hidden) .ant-select-item-option-content"
 PLAYWRIGHT_HINT = (
-    "run the suite under an interpreter carrying Playwright, e.g. "
-    "`uv run --with pyyaml --with playwright python3 scripts/test_e2e.py`, and "
-    "`playwright install chrome` where Google Chrome is not installed"
+    "run the suite through uv, which installs the Playwright it locks "
+    "(`make test-e2e`, or `uv run --locked --script scripts/test_e2e.py`), and install "
+    "Google Chrome where it is absent (`uvx playwright install chrome`)"
 )
 
 
diff --git a/scripts/_stack_state.py b/scripts/_stack_state.py
new file mode 100644
index 0000000..25c811c
--- /dev/null
+++ b/scripts/_stack_state.py
@@ -0,0 +1,210 @@
+#  Project:      dfe-docker
+#  File:         _stack_state.py
+#  Purpose:      The containers a compose project holds, and the commands that start them again
+#  Language:     Python
+#
+#  License:      BUSL-1.1
+#  Copyright:    (c) 2026 HYPERI PTY LIMITED
+
+"""What a compose project was running before the e2e suite, read off `docker inspect`.
+
+Internal support module - imported by the e2e suite, not executed directly. The
+suite stops every service to run one stack per test, so it reads the project
+first and starts the same services from the same compose files at the end. Compose
+labels each container with the files, directory and project it came from, and
+with a hash of its resolved config, which says whether the container that comes
+back is configured as the one that went.
+"""
+
+from collections import defaultdict
+from collections.abc import Callable, Iterable, Mapping
+from dataclasses import dataclass
+
+SERVICE_LABEL = "com.docker.compose.service"
+PROJECT_LABEL = "com.docker.compose.project"
+CONFIG_FILES_LABEL = "com.docker.compose.project.config_files"
+WORKING_DIR_LABEL = "com.docker.compose.project.working_dir"
+ENVIRONMENT_FILE_LABEL = "com.docker.compose.project.environment_file"
+CONFIG_HASH_LABEL = "com.docker.compose.config-hash"
+ONEOFF_LABEL = "com.docker.compose.oneoff"
+
+
+@dataclass(frozen=True, slots=True)
+class Container:
+    """One service container, as compose labelled it and docker reports it.
+
+    Attributes:
+        service: The compose service it runs.
+        running: Whether its process is running.
+        exit_code: The code its process last exited with.
+        restart: Its restart policy, empty when none was set.
+        config_hash: The hash compose took of the service's resolved config.
+        project: The compose project it belongs to.
+        working_dir: The project directory compose resolved relative paths against.
+        config_files: The compose files it was started from, in order.
+        environment_files: The `--env-file` arguments it was started with.
+    """
+
+    service: str
+    running: bool
+    exit_code: int
+    restart: str
+    config_hash: str
+    project: str
+    working_dir: str
+    config_files: tuple[str, ...]
+    environment_files: tuple[str, ...]
+
+    @property
+    def run_to_completion(self) -> bool:
+        """A one-shot that finished cleanly, which `up` runs to completion again."""
+        return not (self.running) and self.exit_code == 0 and self.restart in ("", "no")
+
+    @property
+    def restored(self) -> bool:
+        """Started again at the end: running, or a one-shot that finished cleanly."""
+        return self.running or self.run_to_completion
+
+
+def _split(value: str) -> tuple[str, ...]:
+    return tuple(part for part in value.split(",") if part)
+
+
+def containers(documents: Iterable[Mapping]) -> list[Container]:
+    """Every service container in `docker inspect` output, `docker compose run` ones left out."""
+    found = []
+    for document in documents:
+        labels = (document.get("Config") or {}).get("Labels") or {}
+        if not (labels.get(SERVICE_LABEL)) or labels.get(ONEOFF_LABEL) == "True":
+            continue
+        state = document.get("State") or {}
+        policy = (document.get("HostConfig") or {}).get("RestartPolicy") or {}
+        found.append(
+            Container(
+                service=labels[SERVICE_LABEL],
+                running=bool(state.get("Running")),
+                exit_code=int(state.get("ExitCode") or 0),
+                restart=policy.get("Name") or "",
+                config_hash=labels.get(CONFIG_HASH_LABEL, ""),
+                project=labels.get(PROJECT_LABEL, ""),
+                working_dir=labels.get(WORKING_DIR_LABEL, ""),
+                config_files=_split(labels.get(CONFIG_FILES_LABEL, "")),
+                environment_files=_split(labels.get(ENVIRONMENT_FILE_LABEL, "")),
+            )
+        )
+    return sorted(found, key=lambda container: container.service)
+
+
+@dataclass(frozen=True, slots=True)
+class Restore:
+    """One `docker compose up` that starts services from the files they came from.
+
+    Attributes:
+        missing: Compose files the services were started from that no longer exist,
+            left out of the command, and the config hash check judges what that
+            changed.
+    """
+
+    project: str
+    working_dir: str
+    config_files: tuple[str, ...]
+    environment_files: tuple[str, ...]
+    services: tuple[str, ...]
+    missing: tuple[str, ...] = ()
+
+    def compose(self) -> list[str]:
+        """`docker compose` on the project, directory and files the services came from."""
+        command = ["docker", "compose", "--project-name", self.project]
+        command += ["--project-directory", self.working_dir]
+        for path in self.environment_files:
+            command += ["--env-file", path]
+        for path in self.config_files:
+            command += ["-f", path]
+        return command
+
+    def config(self) -> list[str]:
+        """The command that prints every service those files define, as JSON."""
+        return self.compose() + ["--profile", "*", "config", "--format", "json"]
+
+    def command(self, profiles: Iterable[str] = ()) -> list[str]:
+        """The `up`, with only the given profiles enabled.
+
+        Every profile at once is wrong: both brokers are optional dependencies
+        of dfe-engine, and the profile is what picks which one starts.
+        """
+        flags = [
+            part for profile in sorted(set(profiles)) for part in ("--profile", profile)
+        ]
+        return self.compose() + flags + ["up", "-d", *self.services]
+
+
+def profiles_of(model: Mapping, services: Iterable[str]) -> set[str]:
+    """The profiles the named services belong to, from `docker compose config` JSON."""
+    defined = model.get("services") or {}
+    return {
+        profile
+        for service in services
+        for profile in (defined.get(service) or {}).get("profiles") or ()
+    }
+
+
+def restores(
+    found: Iterable[Container], *, exists: Callable[[str], bool] = lambda path: True
+) -> list[Restore]:
+    """One `up` per set of compose files the restored containers were started from.
+
+    A file `exists` rejects is left out, as an e2e run's own override is once the
+    run has cleaned up after itself.
+    """
+    groups: dict[tuple, list[str]] = defaultdict(list)
+    for container in found:
+        if container.restored:
+            key = (
+                container.project,
+                container.working_dir,
+                container.config_files,
+                container.environment_files,
+            )
+            groups[key].append(container.service)
+    return [
+        Restore(
+            project,
+            working_dir,
+            tuple(path for path in files if exists(path)),
+            env_files,
+            tuple(sorted(services)),
+            missing=tuple(path for path in files if not (exists(path))),
+        )
+        for (project, working_dir, files, env_files), services in sorted(groups.items())
+    ]
+
+
+def differences(before: Iterable[Container], after: Iterable[Container]) -> list[str]:
+    """How the project differs from how it was found, empty when it does not.
+
+    Each restored service must have a container configured as before, still
+    running if it was. Nothing may be running that was not.
+    """
+    before = list(before)
+    now = {container.service: container for container in after}
+    problems = []
+    for was in before:
+        if not (was.restored):
+            continue
+        current = now.get(was.service)
+        if current is None:
+            problems.append(f"'{was.service}' has no container")
+        elif was.running and not (current.running):
+            problems.append(f"'{was.service}' is not running")
+        elif current.config_hash != was.config_hash:
+            problems.append(
+                f"'{was.service}' is configured differently (config hash "
+                f"{was.config_hash[:12]} became {current.config_hash[:12]})"
+            )
+    was_running = {container.service for container in before if container.running}
+    problems += [
+        f"'{service}' is running and was not"
+        for service, current in sorted(now.items())
+        if current.running and service not in was_running
+    ]
+    return problems
diff --git a/scripts/post.py b/scripts/post.py
index d730271..d684202 100644
--- a/scripts/post.py
+++ b/scripts/post.py
@@ -89,6 +89,7 @@
     MARKER_EXPRESSIONS,
     _decoded,
     ch_count,
+    ch_execute,
     ch_int,
     ch_marker_count,
     ch_query,
@@ -116,6 +117,15 @@
 LAND_TIMEOUT_SECONDS = 60.0
 LAND_INTERVAL_SECONDS = 3.0
 
+# Both deletes run asynchronously and the rows are polled until gone, so a large
+# table cannot hold a request past its timeout.
+CLEANUP_TIMEOUT_SECONDS = 60.0
+CLEANUP_INTERVAL_SECONDS = 2.0
+CLEANUP_STATEMENT_TIMEOUT_SECONDS = 30
+# How ClickHouse refuses a lightweight DELETE on a table with projections, under a
+# table-level lightweight_mutation_projection_mode that no query setting overrides.
+PROJECTION_REFUSAL = ("Code: 344", "projection")
+
 # How long to wait for the ingest component to report ready. `make dev`/`make ci`
 # do not pass `--wait` to `docker compose up`, so this runs while containers are
 # still warming; a single probe would decide "not ready" a second after boot.
@@ -749,28 +759,89 @@ def _run_id() -> str:
     return f"post-{os.getpid()}-{os.urandom(4).hex()}"
 
 
-def _cleanup(database: str, table: str, marker: str) -> None:
-    """Report that this run's synthetic rows remain. It cannot remove them.
+def _marker_predicate(database: str, table: str, marker: str) -> str | None:
+    """The WHERE clause that finds this run's rows, or None when none can be found."""
+    escaped = escape_literal(marker)
+    for expression in MARKER_EXPRESSIONS:
+        where = f"{expression} = '{escaped}'"
+        if (ch_int(f"SELECT count() FROM {database}.{table} WHERE {where}") or 0) > 0:
+            return where
+    return None
+
+
+def _refused_for_projections(answer: str) -> bool:
+    """Whether ClickHouse refused a lightweight DELETE because the table has projections."""
+    return all(part in answer for part in PROJECTION_REFUSAL)
+
+
+def _mutation_failure(database: str, table: str, marker: str) -> str:
+    """The last failure of this run's unfinished delete mutation, or empty."""
+    return ch_query(
+        "SELECT latest_fail_reason FROM system.mutations "
+        f"WHERE database = '{escape_literal(database)}' "
+        f"AND table = '{escape_literal(table)}' AND NOT is_done "
+        f"AND position(command, '{escape_literal(marker)}') > 0 LIMIT 1"
+    )
 
-    We tried deleting them and it does not work: the engine-provisioned
-    `dfe.main` carries PROJECTIONS, and ClickHouse refuses a lightweight
-    DELETE on such a table unless `lightweight_mutation_projection_mode` is
-    changed:
 
-        Code: 344. DELETE query is not allowed for table dfe.main because
-        as it has projections and setting lightweight_mutation_projection_mode
-        is set to THROW.
+def _cleanup(database: str, table: str, marker: str) -> None:
+    """Delete this run's synthetic rows, by mutation where a lightweight DELETE is refused.
 
-    Changing a server-level mutation setting to tidy up after a self test is a
-    worse trade than leaving three rows, so it says so instead. The rows are
-    identifiable (`post-<pid>-<hex>` in `_tags.marker`) if you want them gone.
+    A table the engine created before it stopped adding the `_timestamp_optimized`
+    projection still carries it, and ClickHouse refuses a lightweight DELETE there
+    (Code 344) while the table's `lightweight_mutation_projection_mode` is `throw`.
+    A mutation (`ALTER TABLE ... DELETE`) rebuilds the projection with the parts it
+    rewrites, so it is the fallback, and the table's setting is left alone.
 
-    Writing to the real landing table is deliberate: a dedicated table would
-    prove a different pipeline than the one being asserted.
+    Tidy-up only: what it could not remove is reported, never failed. Writing to
+    the real landing table is deliberate, because a dedicated table would prove a
+    different pipeline than the one being asserted.
     """
+    where = _marker_predicate(database, table, marker)
+    if where is None:
+        _print(
+            msg=f"      note: no row tagged {marker} in {database}.{table} to remove"
+        )
+        return
+
+    how = "lightweight DELETE"
+    deleted, answer = ch_execute(
+        f"DELETE FROM {database}.{table} WHERE {where} "
+        "SETTINGS lightweight_deletes_sync = 0",
+        timeout=CLEANUP_STATEMENT_TIMEOUT_SECONDS,
+    )
+    if not (deleted) and _refused_for_projections(answer):
+        how = "mutation, as the table's projections refuse a lightweight DELETE"
+        deleted, answer = ch_execute(
+            f"ALTER TABLE {database}.{table} DELETE WHERE {where} "
+            "SETTINGS mutations_sync = 0",
+            timeout=CLEANUP_STATEMENT_TIMEOUT_SECONDS,
+        )
+    if not (deleted):
+        refusal = answer.splitlines()[0] if answer else "no answer"
+        _print(
+            msg=f"      note: {EVENT_COUNT} synthetic row(s) remain in {database}.{table} "
+            f"tagged {marker} -- the {how} was refused: {refusal}"
+        )
+        return
+
+    left = poll_until(
+        lambda: ch_int(f"SELECT count() FROM {database}.{table} WHERE {where}"),
+        timeout=CLEANUP_TIMEOUT_SECONDS,
+        interval=CLEANUP_INTERVAL_SECONDS,
+        done=lambda count: count == 0,
+    )
+    if left == 0:
+        _print(
+            msg=f"      removed the synthetic rows tagged {marker} from "
+            f"{database}.{table} by {how}"
+        )
+        return
+    failure = _mutation_failure(database, table, marker)
     _print(
-        msg=f"      note: {EVENT_COUNT} synthetic row(s) remain in {database}.{table} "
-        f"tagged {marker} -- lightweight DELETE is refused on a table with projections"
+        msg=f"      note: {left} synthetic row(s) tagged {marker} remain in "
+        f"{database}.{table} {CLEANUP_TIMEOUT_SECONDS:.0f}s after the {how}"
+        + (f": {failure}" if failure else " -- system.mutations carries its progress")
     )
 
 
@@ -2270,25 +2341,23 @@ def _report(attempt, result):
         _print(
             msg=f"PASS  {matched}/{EVENT_COUNT} marked event(s) landed in {database}.{table}"
         )
-        _cleanup(database, table, marker)
         # Every remaining claim runs even when an earlier one fails, so one boot
         # reports every broken pipeline rather than the first one.
-        return _report_claims(
-            claims={
-                "ingest": HELD,
-                "hunts": _verify_hunt(
-                    database=database, ingest_url=ingest_url, marker=marker, table=table
-                ),
-                "subscription": _verify_loader_subscription(),
-                "self-monitoring": _verify_self_monitoring(),
-                "observability": _verify_hyperdx(),
-                "console": _verify_ui_query(
-                    database=database, marker=marker, table=table
-                ),
-                "idle apps": _verify_idle_apps(),
-                "routing": _verify_routing_applied(database=database),
-            }
-        )
+        claims = {
+            "ingest": HELD,
+            "hunts": _verify_hunt(
+                database=database, ingest_url=ingest_url, marker=marker, table=table
+            ),
+            "subscription": _verify_loader_subscription(),
+            "self-monitoring": _verify_self_monitoring(),
+            "observability": _verify_hyperdx(),
+            "console": _verify_ui_query(database=database, marker=marker, table=table),
+            "idle apps": _verify_idle_apps(),
+            "routing": _verify_routing_applied(database=database),
+        }
+        # After the console claim, which reads these same rows back.
+        _cleanup(database, table, marker)
+        return _report_claims(claims=claims)
 
     _print(
         msg=f"FAIL  only {matched}/{EVENT_COUNT} marked event(s) reached "
diff --git a/scripts/test_e2e.py b/scripts/test_e2e.py
index c593906..48eedd8 100755
--- a/scripts/test_e2e.py
+++ b/scripts/test_e2e.py
@@ -1,4 +1,4 @@
-#!/usr/bin/env python3
+#!/usr/bin/env -S uv run --locked --script
 
 #  Project:   dfe-docker
 #  File:      scripts/test-e2e.py
@@ -16,12 +16,21 @@
 #    TEST_CONFIG=tests/e2e/e2e-tests.yaml ./scripts/test-e2e.py  # Custom config
 #    LOG_LEVEL=debug ./scripts/test-e2e.py                       # Verbose service logs
 
+# /// script
+# requires-python = ">=3.12"
+# dependencies = [
+#     "playwright==1.63.0",
+#     "pyyaml==6.0.3",
+# ]
+# ///
+
 import argparse
 import functools
 import json
 import logging
 import os
 import secrets
+import signal
 import ssl
 import subprocess
 import sys
@@ -31,15 +40,14 @@
 try:
     import yaml
 except ModuleNotFoundError:  # pragma: no cover - environment guard
-    # PyYAML is the harness's only third-party dependency and it is NOT in the
-    # stdlib, so a plain `make test-e2e` on a fresh machine dies with a bare
-    # ModuleNotFoundError that says nothing about how to proceed. Every other
-    # missing prerequisite here (docker) gets an actionable message; this one
-    # should too.
+    # An interpreter that skipped the inline metadata above, such as a bare
+    # `python3 scripts/test_e2e.py`, otherwise dies with a ModuleNotFoundError
+    # that does not say how to proceed.
     sys.exit(
-        "test_e2e: PyYAML is required and not installed.\n"
-        "  Install it:      pip install pyyaml\n"
-        "  Or run via uv:   uv run --with pyyaml python3 scripts/test_e2e.py"
+        "test_e2e: PyYAML is not installed in this interpreter.\n"
+        "  Run it through uv, which installs what the script locks:\n"
+        "    make test-e2e\n"
+        "    uv run --locked --script scripts/test_e2e.py"
     )
 
 from collections import Counter
@@ -55,6 +63,7 @@
 import _detection
 import _outage
 import _search_rule
+import _stack_state
 import post
 from _common import FALSY, _config_argument, _load_dotenv, _use_mounted_configs
 from _pipeline import MARKER_EXPRESSIONS  # noqa: F401 - re-exported for callers
@@ -67,6 +76,7 @@
     expand_env,
     otel_fresh_counts,
     poll_until,
+    post_all,
 )
 
 
@@ -151,6 +161,11 @@
 ARCHIVE_INTERVAL_SECONDS = 10
 TARGET_DB = "dfe"
 TARGET_TABLE = "main"
+# The receiver answers each request once the loader has flushed it, which one
+# sender at a time waits out per event, so a data file goes in this many at once.
+SEND_WORKERS = 16
+# How long the services the run found have, together, to come back healthy.
+RESTORE_TIMEOUT_SECONDS = 300
 
 # Marker lookup lives in _pipeline, shared with the power-on self test.
 
@@ -163,7 +178,10 @@
 # - Every rendered-config variable is then blanked. `make` exports the engine's
 #   render paths, and compose inherits them unless each service is sent back to
 #   the config this suite mounts for it.
+# - FOUND_ENVIRON keeps the environment as the run received it, the one the
+#   services it found are started again under.
 # ------------------------------------------------------------------------------
+FOUND_ENVIRON = dict(os.environ)
 _load_dotenv()
 _use_mounted_configs(environ=os.environ)
 
@@ -1031,6 +1049,118 @@ def container_id(service):
     return ids[0] if (result.returncode == 0 and ids) else ""
 
 
+# ------------------------------------------------------------------------------
+# Project Containers
+# - Every service container in THIS compose project, stopped or not, as
+#   _stack_state reads them, or None when docker could not say
+# ------------------------------------------------------------------------------
+def project_containers():
+    listed = run_cmd(
+        ["docker", "compose", "--profile", "*", "ps", "--all", "--quiet"], capture=True
+    )
+    if listed.returncode != 0:
+        LOGGER.error(f"Could not list this project's containers: {listed.stderr}")
+        return None
+    ids = (listed.stdout or "").split()
+    if not (ids):
+        return []
+    inspected = run_cmd(["docker", "inspect", *ids], capture=True)
+    try:
+        return _stack_state.containers(json.loads(inspected.stdout or "[]"))
+    except ValueError:
+        LOGGER.error(f"Could not inspect this project's containers: {inspected.stderr}")
+        return None
+
+
+# ------------------------------------------------------------------------------
+# Wait Settled
+# - Polls until one service is back as it was found: running and healthy, or a
+#   one-shot that has finished, or the deadline passes
+# ------------------------------------------------------------------------------
+def wait_settled(container, deadline):
+    while True:
+        state = container_state(container.service)
+        if state and container.running:
+            if state.status == "running" and state.health in ("healthy", ""):
+                return
+        elif state and state.status != "running":
+            return
+        if time.monotonic() >= deadline:
+            return
+        time.sleep(2)
+
+
+# ------------------------------------------------------------------------------
+# Put Back
+# - Leaves the project as the run found it: the test stack down, then each service
+#   that was running, or had run to completion, started again from the compose
+#   files, project and environment it was started with, and checked against the
+#   config hash compose recorded for it
+# ------------------------------------------------------------------------------
+def put_back(ctx, found):
+    print()
+    stack_down()
+
+    for restore in _stack_state.restores(found, exists=os.path.exists):
+        LOGGER.info(
+            f"Starting the {len(restore.services)} service(s) this run found, from "
+            f"{len(restore.config_files)} compose file(s)..."
+        )
+        if restore.missing:
+            LOGGER.warning(
+                f"    Left out, as they no longer exist: {', '.join(restore.missing)}"
+            )
+        run = functools.partial(
+            subprocess.run,
+            cwd=restore.working_dir or PROJECT_DIR,
+            env=FOUND_ENVIRON,
+            capture_output=True,
+            text=True,
+            encoding="utf-8",
+            errors="replace",
+        )
+        config = run(restore.config())
+        try:
+            model = json.loads(config.stdout) if (config.returncode == 0) else None
+        except ValueError:
+            model = None
+        if model is None:
+            mark_fail(
+                ctx,
+                "the services this run found are not started again: compose could "
+                f"not resolve the files they came from: {config.stderr.strip()}",
+            )
+            continue
+        result = run(restore.command(_stack_state.profiles_of(model, restore.services)))
+        if result.returncode != 0:
+            detail = (result.stderr or result.stdout or "").strip()
+            mark_fail(ctx, f"the services this run found did not start again: {detail}")
+
+    deadline = time.monotonic() + RESTORE_TIMEOUT_SECONDS
+    for container in found:
+        if container.restored:
+            wait_settled(container, deadline)
+
+    after = project_containers()
+    problems = (
+        ["the project could not be read back"]
+        if (after is None)
+        else _stack_state.differences(found, after)
+    )
+    running = sum(1 for container in found if container.running)
+    completed = sum(1 for container in found if container.run_to_completion)
+    if problems:
+        mark_fail(ctx, f"the stack is not as this run found it: {'; '.join(problems)}")
+    elif running or completed:
+        mark_pass(
+            ctx,
+            f"the stack is as this run found it: {running} service(s) running and "
+            f"{completed} one-shot(s) completed, each on the config it had",
+        )
+    else:
+        mark_pass(ctx, "this run found no stack running and leaves none")
+
+
 # ------------------------------------------------------------------------------
 # Report Unready Service
 # - Dumps what a timed-out service was actually doing, before teardown removes it
@@ -1189,28 +1319,26 @@ def send_events(ctx, test_name, marker, data_file_name, database, table, ingest_
     events = data_file_path.read_text(encoding="utf-8").splitlines()
     num_events = len(events)
 
-    LOGGER.info(f"Sending {num_events} events to '{ingest_url}'...")
+    LOGGER.info(
+        f"Sending {num_events} events to '{ingest_url}' ({SEND_WORKERS} at a time)..."
+    )
     LOGGER.debug(f"Marker: '{marker}'")
 
-    ctx.total_sent = 0
-    send_errors = 0
-
+    bodies = []
     for line in events:
         event = json.loads(line)
         event["_source"] = table
         event["_tags"] = {"marker": marker, "test_name": test_name}
-        enriched = json.dumps(event, separators=(",", ":"))
-
-        try:
-            status = http_post(ingest_url, enriched)
-        except Exception:
-            status = 0
+        bodies.append(json.dumps(event, separators=(",", ":")))
 
+    send_errors = 0
+    for body, status in zip(
+        bodies, post_all(ingest_url, bodies, workers=SEND_WORKERS), strict=True
+    ):
         if status < 200 or status >= 300:
-            LOGGER.debug(f"Response code '{status}' received for '{enriched}'")
+            LOGGER.debug(f"Response code '{status}' received for '{body}'")
             send_errors += 1
-
-        ctx.total_sent += 1
+    ctx.total_sent = len(bodies)
 
     LOGGER.info(f"Sent {ctx.total_sent} events (errors = {send_errors})")
 
@@ -3346,6 +3474,30 @@ def run_test(ctx, mode, test, persistent_services):
     print("------------------------------------------------------------")
 
 
+# ------------------------------------------------------------------------------
+# Run Suite
+# - Reads the project, stops it, builds and runs every test, then puts the project
+#   back as it was found on every way out, a SIGTERM included
+# ------------------------------------------------------------------------------
+def run_suite(ctx, mode, tests, persistent_services):
+    found = project_containers()
+    if found is None:
+        error("the running stack could not be read, so nothing was stopped")
+    signal.signal(signal.SIGTERM, lambda signum, frame: sys.exit(128 + signum))
+    try:
+        if stack_is_up():
+            print()
+            stack_down(persistent_services)
+
+        # Build only the DFE services the selected tests actually need.
+        build_images(mode, {service for test in tests for service in test.services})
+
+        for test in tests:
+            run_test(ctx, mode, test, persistent_services)
+    finally:
+        put_back(ctx, found)
+
+
 # ==============================================================================
 # Miscellaneous Functions
 # ==============================================================================
@@ -3462,12 +3614,7 @@ def main():
     global_config = config.get("global", {}).copy()
     global_config["clickhouse"] = config.get("clickhouse", {})
 
-    # Tear down any existing stack before starting
     persistent_services = get_config("persistent_services", {}, global_config)
-    if stack_is_up():
-        print()
-        stack_down(persistent_services)
-
     mode = get_config("mode", {}, global_config)
 
     # Resolve which tests to run - CLI args filter, otherwise every test of the
@@ -3496,16 +3643,8 @@ def main():
             if bool(test_config.get("outage")) == args.outages:
                 tests_to_run.append(resolve_test_case(test_config, global_config))
 
-    # Build only the DFE services the selected tests actually need.
-    all_services = set()
-    for test in tests_to_run:
-        all_services.update(test.services.keys())
-
-    build_images(mode, all_services)
-
-    # Run resolved tests
-    for test in tests_to_run:
-        run_test(ctx, mode, test, persistent_services)
+    if tests_to_run:
+        run_suite(ctx, mode, tests_to_run, persistent_services)
 
     # Post test execution cleanup
     cleanup(global_config.get("clickhouse", {}))
diff --git a/scripts/test_e2e.py.lock b/scripts/test_e2e.py.lock
new file mode 100644
index 0000000..807652e
--- /dev/null
+++ b/scripts/test_e2e.py.lock
@@ -0,0 +1,162 @@
+version = 1
+revision = 5
+requires-python = ">=3.12"
+
+[manifest]
+requirements = [
+    { name = "playwright", specifier = "==1.63.0" },
+    { name = "pyyaml", specifier = "==6.0.3" },
+]
+
+[[package]]
+name = "greenlet"
+version = "3.5.6"
+source = { registry = "https://pypi.org/simple" }
+sdist = { url = "https://files.pythonhosted.org/packages/3e/6e/0091f175ccd02b02bc8811bbcbcc6ac2e980be116e3b2f7a736ca322bf84/greenlet-3.5.6.tar.gz", hash = "sha256:8e67c43bdfc88d5fee6db0d3e40175b362fc95fb85f0412d233b9b203c53a575", size = 207653, upload-time = "2026-09-14T15:42:51.806Z" }
+wheels = [
+    { url = "https://files.pythonhosted.org/packages/72/18/3fc6d951466ae9a2a688edcddde3b2e388da0a8244e0caf7117bbeb0eb95/greenlet-3.5.6-cp312-cp312-macosx_11_0_universal2.whl", hash = "sha256:a5876d0a60355af98d535c47f6cd6eb0f8a432396dab26845d380b92f8412422", size = 295668, upload-time = "2026-09-14T14:22:33.241Z" },
+    { url = "https://files.pythonhosted.org/packages/27/89/366d2af5061eeefa5012f510d95a99c8620dcc457609838db4d538820318/greenlet-3.5.6-cp312-cp312-manylinux_2_24_aarch64.manylinux_2_28_aarch64.whl", hash = "sha256:e85880b538e59a59f55117b81f208a6660ad5ac328aad9305f812d9b8bc67a0f", size = 611700, upload-time = "2026-09-14T15:12:01.962Z" },
+    { url = "https://files.pythonhosted.org/packages/54/1c/07f133f865fd58ae593dd2bbec3144acaee9b04ffe2eb48c6e121747ceef/greenlet-3.5.6-cp312-cp312-manylinux_2_24_ppc64le.manylinux_2_28_ppc64le.whl", hash = "sha256:f0ba7c2a329d650628f4c8572fd1db29f0a59dd70a3e3e0710dcf18a35cce9d8", size = 624223, upload-time = "2026-09-14T15:20:42.459Z" },
+    { url = "https://files.pythonhosted.org/packages/a7/f2/844dc823ff2752ad049caa6b59d57e4572f9c445934b02d3518f4c67197c/greenlet-3.5.6-cp312-cp312-manylinux_2_24_s390x.manylinux_2_28_s390x.whl", hash = "sha256:ee7d9da3bf493909cf811a3f038840cb34fab5ae2956b8a263919f6e289ab188", size = 629529, upload-time = "2026-09-14T15:25:06.354Z" },
+    { url = "https://files.pythonhosted.org/packages/66/6a/1594f3869c57c149abdb380492529e04d4c0229b5e4d79572c5bd0aaa673/greenlet-3.5.6-cp312-cp312-manylinux_2_24_x86_64.manylinux_2_28_x86_64.whl", hash = "sha256:975736b002ed080d124cf81a79cb7e05cb26d6b3f5c7a7b651c0fcce70353aa1", size = 621404, upload-time = "2026-09-14T14:35:59.027Z" },
+    { url = "https://files.pythonhosted.org/packages/c0/42/b1f8dbc89a53b9e77859fc1ad1627d106fc361daa3ea4bdf43a91ebb4338/greenlet-3.5.6-cp312-cp312-manylinux_2_39_riscv64.whl", hash = "sha256:71890d5247020c25c21a6b65202782bfc281d4e6e244842419d30e3492bb6dcc", size = 432385, upload-time = "2026-09-14T15:28:37.369Z" },
+    { url = "https://files.pythonhosted.org/packages/a2/f5/33e5c9e48178b9259fd000f8f45caa4a65036f65d3d0c06a602f570f025d/greenlet-3.5.6-cp312-cp312-musllinux_1_2_aarch64.whl", hash = "sha256:0616b8f878098c5681fd8f0dc92d887551717402342a70f0abcbfea5f5ad8a44", size = 1584998, upload-time = "2026-09-14T15:10:06.653Z" },
+    { url = "https://files.pythonhosted.org/packages/ef/31/9b4e140bc24d0ad7927ebd651f5608b0acc2334d061748c3b6ad19085cfa/greenlet-3.5.6-cp312-cp312-musllinux_1_2_x86_64.whl", hash = "sha256:3dbb4596a6a4e5d47121a33ff20533a81e60f302d9e67b69909a8bc21a43f0a7", size = 1647568, upload-time = "2026-09-14T14:35:49.787Z" },
+    { url = "https://files.pythonhosted.org/packages/c3/71/d79f1791f824f8ff15c2978746640467ae932a2365e0201069f7f272395f/greenlet-3.5.6-cp312-cp312-win_amd64.whl", hash = "sha256:7ac4abb3877c43af320392c664774eef6fa2cc063c79a55fc02d844a3cbe7395", size = 324203, upload-time = "2026-09-14T14:22:54.504Z" },
+    { url = "https://files.pythonhosted.org/packages/63/af/42aca4d56e8cb321912203069d8d34734cb288222f10ad2ae102718cc577/greenlet-3.5.6-cp312-cp312-win_arm64.whl", hash = "sha256:301102a49120b095e72a7838792b41233975fc1c155daec6d98f81c00c9280e0", size = 308310, upload-time = "2026-09-14T14:24:03.008Z" },
+    { url = "https://files.pythonhosted.org/packages/f1/a1/e720a38852366c589e1a46cf570b886507ad2cf591050c203365638baab0/greenlet-3.5.6-cp313-cp313-macosx_11_0_universal2.whl", hash = "sha256:f96f0e30b5a95c7631b12bfe214cbc90ec8fe8cfa36920596c10514a65743519", size = 294627, upload-time = "2026-09-14T14:24:40.102Z" },
+    { url = "https://files.pythonhosted.org/packages/eb/c3/58187858df41354a11e6a55b421e7af9059798abdab3a384cc51b8567c38/greenlet-3.5.6-cp313-cp313-manylinux_2_24_aarch64.manylinux_2_28_aarch64.whl", hash = "sha256:c75116c9de79949de23006e2d9b35ee82874c594fcf5c0311b439acaa14b8441", size = 614356, upload-time = "2026-09-14T15:12:03.399Z" },
+    { url = "https://files.pythonhosted.org/packages/ce/b9/3a7e67d5f05c9760b1ad411fa52264bd69cc08e22a2ebfb4018b90628ced/greenlet-3.5.6-cp313-cp313-manylinux_2_24_ppc64le.manylinux_2_28_ppc64le.whl", hash = "sha256:cad5782f93f7f738b62c6527b6f32a60694d924029f299a8b524758cfa53d815", size = 626756, upload-time = "2026-09-14T15:20:44.269Z" },
+    { url = "https://files.pythonhosted.org/packages/c6/7c/40400455f5b5a65bb83e94fde66d1be9e5ec518638113f8083ace746c309/greenlet-3.5.6-cp313-cp313-manylinux_2_24_s390x.manylinux_2_28_s390x.whl", hash = "sha256:a93ee7c6e8fd0f8a83525a51bd777be57ee17787e91d805bd8d6faf9dcada18e", size = 632632, upload-time = "2026-09-14T15:25:07.813Z" },
+    { url = "https://files.pythonhosted.org/packages/85/cb/ab0c123c514ed4e94c0dc9ee2e86362633e6b998cfc05de7fc9ac2eb9690/greenlet-3.5.6-cp313-cp313-manylinux_2_24_x86_64.manylinux_2_28_x86_64.whl", hash = "sha256:f98e8215e172f567ce80eeaed9107fb4d32b6c44f26983d9b8334658136a205a", size = 623779, upload-time = "2026-09-14T14:36:01.104Z" },
+    { url = "https://files.pythonhosted.org/packages/f9/67/1f35cff30a6c51c3f23b63d4afcc7313ab4f97490ba3676fa78178984b27/greenlet-3.5.6-cp313-cp313-manylinux_2_39_riscv64.whl", hash = "sha256:7f731ebac68ea06d628658295cb2d217b10186329fcf9a3b6a149045059bf92e", size = 434933, upload-time = "2026-09-14T15:28:38.858Z" },
+    { url = "https://files.pythonhosted.org/packages/a5/26/fda8a5a06e7073333ccb038133c5893b9e0c4fe29d5992a17e83c241bc6e/greenlet-3.5.6-cp313-cp313-musllinux_1_2_aarch64.whl", hash = "sha256:df19e2d0b1620039af5102563fbd96e8938c7f5c3f5828528d641d9fc585525e", size = 1584930, upload-time = "2026-09-14T15:10:08.234Z" },
+    { url = "https://files.pythonhosted.org/packages/2f/37/50f8813163148d6234e08b23dcad6a9e37f01d148c8ec976e4c44ea2d918/greenlet-3.5.6-cp313-cp313-musllinux_1_2_x86_64.whl", hash = "sha256:06c0e933290fba8ffe53ead4ae1b8044b0e9754b75cebf381aa2bc3e50d82fac", size = 1647590, upload-time = "2026-09-14T14:35:51.173Z" },
+    { url = "https://files.pythonhosted.org/packages/86/da/b7669b09586365654083a62bd0724cf06cb74bd5085a15cdd161271f992f/greenlet-3.5.6-cp313-cp313-win_amd64.whl", hash = "sha256:5b602b4201b965a8354d74e232364a66ff243dd142e350d035f46169bb36e13d", size = 324086, upload-time = "2026-09-14T14:23:48.428Z" },
+    { url = "https://files.pythonhosted.org/packages/e5/5d/c9663cfe84a2a9e0aa96f066f5b0594c227ea4c647511e087e2e11d4ac0a/greenlet-3.5.6-cp313-cp313-win_arm64.whl", hash = "sha256:876077e7ebb8c84ed068e2b23d4c62ebb010d60df84b9591af1be2f39010ffb2", size = 308211, upload-time = "2026-09-14T14:28:01.634Z" },
+    { url = "https://files.pythonhosted.org/packages/66/c0/d254544ae2b8bdd311aef000fafc02828c2771b17d994b3075620ea7cc6e/greenlet-3.5.6-cp314-cp314-macosx_11_0_universal2.whl", hash = "sha256:8cddea1b8339451c2fb3388e138347b6126744f33b611bdb55b7357361cfef46", size = 295221, upload-time = "2026-09-14T14:25:11.583Z" },
+    { url = "https://files.pythonhosted.org/packages/18/18/eb54be16b9cc3971e09ca5b73334e1b8c804a4630d9addaaf218a4fe300f/greenlet-3.5.6-cp314-cp314-manylinux_2_24_aarch64.manylinux_2_28_aarch64.whl", hash = "sha256:c59acfa8eb73a1e0d484392dc002bdf001fd4ce73394e0132df3d1ab6093d7cb", size = 660992, upload-time = "2026-09-14T15:12:04.876Z" },
+    { url = "https://files.pythonhosted.org/packages/8f/b4/e193efe65671dcf294bc51fcc59efb52d154adf8612c4ea016da0d2c486c/greenlet-3.5.6-cp314-cp314-manylinux_2_24_ppc64le.manylinux_2_28_ppc64le.whl", hash = "sha256:a3b4a01c6da07ef9f80d4fe8933b994bc99747bcea3eab0330a9c34d3c12655b", size = 673428, upload-time = "2026-09-14T15:20:45.756Z" },
+    { url = "https://files.pythonhosted.org/packages/fd/21/631bb45fafde1dca782152377c0676d182ec924820064047f533a3627b28/greenlet-3.5.6-cp314-cp314-manylinux_2_24_s390x.manylinux_2_28_s390x.whl", hash = "sha256:dd0b83bed3405b586a3133629f1d1a5bc7bfd64822a3b7ab342bdc68e6dbc61b", size = 677688, upload-time = "2026-09-14T15:25:09.279Z" },
+    { url = "https://files.pythonhosted.org/packages/45/ac/28fa7a9e50f2859466214c4ac584d776db52c1604ad4dd158960a5af2a1f/greenlet-3.5.6-cp314-cp314-manylinux_2_24_x86_64.manylinux_2_28_x86_64.whl", hash = "sha256:9a09d59bef1db94f384b5bcc2d523694d338f3df6b757aeeaf7baca5d0c0be88", size = 670773, upload-time = "2026-09-14T14:36:02.577Z" },
+    { url = "https://files.pythonhosted.org/packages/40/30/2b0a73e68e1e18e30b601d0d183cfdfc2beca4de5a6843c630f0fc9fb90c/greenlet-3.5.6-cp314-cp314-manylinux_2_39_riscv64.whl", hash = "sha256:fdacf26402389bdd89857ad3c045a26fe8f3314f9a8b28226f82f88463a65b77", size = 480475, upload-time = "2026-09-14T15:28:40.741Z" },
+    { url = "https://files.pythonhosted.org/packages/c3/cd/fb7d6cdd86ff3427c1494854f0e35437eba05142be91f530f6da75e09e19/greenlet-3.5.6-cp314-cp314-musllinux_1_2_aarch64.whl", hash = "sha256:8b7c73d1cef3d9ae963e9ff03f6222df43efbb9054ffd2f1969c935b7fc84c02", size = 1631900, upload-time = "2026-09-14T15:10:09.745Z" },
+    { url = "https://files.pythonhosted.org/packages/f6/40/143bdbb20a516628cb15074ae52ed17d850b450292609c7a6fccac6dbece/greenlet-3.5.6-cp314-cp314-musllinux_1_2_x86_64.whl", hash = "sha256:8b27df301f56e3b3d2298095c8f7d6b68f2521f6b1693e901fa039bdbae34424", size = 1693740, upload-time = "2026-09-14T14:35:52.959Z" },
+    { url = "https://files.pythonhosted.org/packages/c9/9e/019642432e6ae283301df1361227d47610709d2dc69a38f95edef266d713/greenlet-3.5.6-cp314-cp314-win_amd64.whl", hash = "sha256:f8f0bd690e1a41294ac87905e8121c81a3761ec2583c768f13467428606c8c7a", size = 327473, upload-time = "2026-09-14T14:28:12.948Z" },
+    { url = "https://files.pythonhosted.org/packages/e9/7f/8aafc7bf70c948786dba7221d0dc0838e5329bebc6d434ef2208b4f0e760/greenlet-3.5.6-cp314-cp314-win_arm64.whl", hash = "sha256:8cda13494d86a4f12429641117cb6ac4bbbc9c30a33f711f7d3a2e5fbe4b0b7e", size = 311095, upload-time = "2026-09-14T14:28:00.7Z" },
+    { url = "https://files.pythonhosted.org/packages/14/7e/7a205688a5b3074933b18a906608d46d106e9a79d776bdab5a4abf4b4feb/greenlet-3.5.6-cp314-cp314t-macosx_11_0_universal2.whl", hash = "sha256:97c5a53e8c1754df58e73f047a99e287d4da1bdfe64b0072fb25c87000897951", size = 305352, upload-time = "2026-09-14T14:21:31.962Z" },
+    { url = "https://files.pythonhosted.org/packages/78/cb/9c4a57a9d9dd0256e20b8f7f4f06554c2c92badebf0ab73ce344321b78b9/greenlet-3.5.6-cp314-cp314t-manylinux_2_24_aarch64.manylinux_2_28_aarch64.whl", hash = "sha256:fea4427d1ffdb3b523d7daa6712038428a4c16c450b9777bdd1221cfee0eab49", size = 672671, upload-time = "2026-09-14T15:12:06.347Z" },
+    { url = "https://files.pythonhosted.org/packages/97/52/c6729681ebbd298f4decd28746815acc8a0b0a0fde21d2df33776fd4d042/greenlet-3.5.6-cp314-cp314t-manylinux_2_24_ppc64le.manylinux_2_28_ppc64le.whl", hash = "sha256:73a29b5ba642e35433166a03a3e02935e7238c4b3467fbd77523b99edea23e5b", size = 679489, upload-time = "2026-09-14T15:20:47.291Z" },
+    { url = "https://files.pythonhosted.org/packages/71/76/3c11c21e0716b1f1dc7c1a4b3d690abb1d3b448c69a9d32049fecb64010a/greenlet-3.5.6-cp314-cp314t-manylinux_2_24_s390x.manylinux_2_28_s390x.whl", hash = "sha256:61a61b4a95a4f97922c3a6f5606d3e360851584bd47e500a5161373c53810e3d", size = 681303, upload-time = "2026-09-14T15:25:11.088Z" },
+    { url = "https://files.pythonhosted.org/packages/58/c5/2b6c721ba8b8963da42d5a0f57f25b8aaeb1fe9bdd156875e57f3be648a2/greenlet-3.5.6-cp314-cp314t-manylinux_2_24_x86_64.manylinux_2_28_x86_64.whl", hash = "sha256:460e70b033aba8ed47e2ac9b5d0d2157b05a34fbfa30a241400aef4118902cdc", size = 676608, upload-time = "2026-09-14T14:36:03.959Z" },
+    { url = "https://files.pythonhosted.org/packages/3f/26/3ae402202452cd5941bbbd483e5a74297e2397e7aa3182c2a5e3ab7d5666/greenlet-3.5.6-cp314-cp314t-manylinux_2_39_riscv64.whl", hash = "sha256:fe3170a69fe039b18ad18171e66faa9a75f6fe9d78f968fd9b54e09fbd714d81", size = 510112, upload-time = "2026-09-14T15:28:42.112Z" },
+    { url = "https://files.pythonhosted.org/packages/b2/04/0d018e0d05bcdde19a0fcb907834155f1fc853a9bedd3f3f5e6acadcae19/greenlet-3.5.6-cp314-cp314t-musllinux_1_2_aarch64.whl", hash = "sha256:ca80a49b53ed1d22f7282da7255f7bb2fd1935fd0f623d8613fda38745f18961", size = 1641479, upload-time = "2026-09-14T15:10:11.216Z" },
+    { url = "https://files.pythonhosted.org/packages/59/bb/f02ef9073919158f6403fe3701d4ed4403d646720e7201dfc6e9d264bac3/greenlet-3.5.6-cp314-cp314t-musllinux_1_2_x86_64.whl", hash = "sha256:916f92f2a8db10508f739d0b5e00b83defe5d1115a997c54532a6d7cf8c95404", size = 1698758, upload-time = "2026-09-14T14:35:54.336Z" },
+    { url = "https://files.pythonhosted.org/packages/08/a5/1f48fe647473a2dcccfd1839b2ff2c78eb57009be776b4da071e901c9bff/greenlet-3.5.6-cp314-cp314t-win_amd64.whl", hash = "sha256:886bcf1870af74c32bc310fd00a6b803445e17e51b7d5a107c7b35c0f362cc16", size = 331574, upload-time = "2026-09-14T14:27:18.451Z" },
+    { url = "https://files.pythonhosted.org/packages/cd/72/3882855a75838faeb54a58aeef4fd77d20b2a86d4bad570c70d41b565dcf/greenlet-3.5.6-cp315-cp315-macosx_11_0_universal2.whl", hash = "sha256:3ac3494c381dab876cad7d0b22f3a722f3e0c8deb3a65b9e7f35ad7f58b8fcb3", size = 295926, upload-time = "2026-09-14T14:27:21.16Z" },
+    { url = "https://files.pythonhosted.org/packages/10/1f/be4d957d8a9b90bcbe8db206548a42134d96222d43e5ed3fc4708fb6e24b/greenlet-3.5.6-cp315-cp315-manylinux_2_24_aarch64.manylinux_2_28_aarch64.whl", hash = "sha256:602024dae6d77e161f4b89491b62ca1d4f19949d79d47b2db057e476d21179d6", size = 666910, upload-time = "2026-09-14T15:12:07.901Z" },
+    { url = "https://files.pythonhosted.org/packages/a1/af/60d62571a7d6de961e4ce7625d6c2faf359345659fc782d2cdf517c34577/greenlet-3.5.6-cp315-cp315-manylinux_2_24_ppc64le.manylinux_2_28_ppc64le.whl", hash = "sha256:f8e63209c3e1e828ee6a457529b4a6d8b05d050fe0ae03a7ae49e967c5d312e0", size = 677415, upload-time = "2026-09-14T15:20:48.817Z" },
+    { url = "https://files.pythonhosted.org/packages/f5/41/b3114c97c10e796010f00a30f51c81470072bca4b53e396ccca87484fcf7/greenlet-3.5.6-cp315-cp315-manylinux_2_24_s390x.manylinux_2_28_s390x.whl", hash = "sha256:9133d68624b1f2e89ec2f554d56aea8a5b0d7168cd9320200ba58d4d794845a4", size = 681337, upload-time = "2026-09-14T15:25:12.812Z" },
+    { url = "https://files.pythonhosted.org/packages/fb/16/ac9e547b611539aaed1870eb1d6ddc57abdd5924b3a99bb9b5f0b44176b8/greenlet-3.5.6-cp315-cp315-manylinux_2_24_x86_64.manylinux_2_28_x86_64.whl", hash = "sha256:ccadce0130fd813ec86ebfe969a6c58b42acc1d0fe55a47525375b740e07b605", size = 675927, upload-time = "2026-09-14T14:36:05.34Z" },
+    { url = "https://files.pythonhosted.org/packages/48/1b/d41861c2fa00968e39e467a495ca8db9ce9b6310a5d9b57561b3d0dc48fa/greenlet-3.5.6-cp315-cp315-manylinux_2_39_riscv64.whl", hash = "sha256:5adcbbfe78bdc242c71740a02e0991cc1b2f34d33c8bb15ca45eee8fd1140942", size = 487339, upload-time = "2026-09-14T15:28:43.497Z" },
+    { url = "https://files.pythonhosted.org/packages/c4/b1/b7ba08d6431121741f1d30be0d5d292e76873325179a63586cd9217b62f6/greenlet-3.5.6-cp315-cp315-musllinux_1_2_aarch64.whl", hash = "sha256:9297fb9c39b9a2c039dbcd306c410bd6906b95244dec3bba4318d36c718c164c", size = 1637236, upload-time = "2026-09-14T15:10:12.442Z" },
+    { url = "https://files.pythonhosted.org/packages/af/c5/3b1cbc68f0c082022fc8717f7fe4b8b13b8d583c52352be37f4e9f55bcd2/greenlet-3.5.6-cp315-cp315-musllinux_1_2_x86_64.whl", hash = "sha256:b374e79ffa7511afc11773aef40a4ccea6191fba1c856ea2f9c56738dca69d7a", size = 1698526, upload-time = "2026-09-14T14:35:56.039Z" },
+    { url = "https://files.pythonhosted.org/packages/de/56/12941ed2711400451c89d544e10f831800a2770f19dd55eac8f0f7f2003b/greenlet-3.5.6-cp315-cp315-win_amd64.whl", hash = "sha256:7969bffa322c097bd46ae595ada6a931cefda613f18ba64587e9cff4cb320756", size = 327739, upload-time = "2026-09-14T14:23:55.768Z" },
+    { url = "https://files.pythonhosted.org/packages/c5/3b/576b9ed5ac929252e340cf60b4bcb6a8515350dc20797064b1922dc4ea75/greenlet-3.5.6-cp315-cp315-win_arm64.whl", hash = "sha256:8dba0129b93e7091dfefaf4cf7000172741bff7f47bf6326fcf17f32fbb54d6b", size = 311715, upload-time = "2026-09-14T14:28:25.154Z" },
+    { url = "https://files.pythonhosted.org/packages/16/c2/86cfc5555a98e12b86966ddbd24fd39af32f71f2f785c6595b7feb2db156/greenlet-3.5.6-cp315-cp315t-macosx_11_0_universal2.whl", hash = "sha256:de3de000d459402cda015068fd135aa50c0bf6f2477a80d4da1e646f123b4e78", size = 306244, upload-time = "2026-09-14T14:27:57.565Z" },
+    { url = "https://files.pythonhosted.org/packages/14/6d/83ffc9d05a75a80ab3a7595dbb1d9604e5d4fc2996d73a8ae2dbd1284900/greenlet-3.5.6-cp315-cp315t-manylinux_2_24_aarch64.manylinux_2_28_aarch64.whl", hash = "sha256:45663c01a4de48b9a64a2ee1509d92d1dfd3afb02b2ccfc9333029d11aef996a", size = 676578, upload-time = "2026-09-14T15:12:09.468Z" },
+    { url = "https://files.pythonhosted.org/packages/5d/d6/c2cf684810e5caded075970aaadea654ecb58b8382b9aecf1d231b936894/greenlet-3.5.6-cp315-cp315t-manylinux_2_24_ppc64le.manylinux_2_28_ppc64le.whl", hash = "sha256:3deccbb57a481e3a408fe61cdfd5c13e0678fc0a30fdd09597917ca87b4be877", size = 684203, upload-time = "2026-09-14T15:20:50.261Z" },
+    { url = "https://files.pythonhosted.org/packages/f2/d1/039c353d5593a97a89699e989324c9bc86af499e6c6152fe0180f5742204/greenlet-3.5.6-cp315-cp315t-manylinux_2_24_s390x.manylinux_2_28_s390x.whl", hash = "sha256:63aff70fe5aac59c72215f42ec39fcb59ff46774fa966e717f8ecb6ee2273577", size = 686023, upload-time = "2026-09-14T15:25:14.528Z" },
+    { url = "https://files.pythonhosted.org/packages/62/19/00e1bee5d2af890dc8f400b54d0b0f9b489965f92bc12b407ff72cc6f469/greenlet-3.5.6-cp315-cp315t-manylinux_2_24_x86_64.manylinux_2_28_x86_64.whl", hash = "sha256:311018b46472fb26ee85870847fb89eb64cc8aaddb617400789d87076f7cfeec", size = 681253, upload-time = "2026-09-14T14:36:06.742Z" },
+    { url = "https://files.pythonhosted.org/packages/8a/62/97ceb8e0b2ea96046cdf8e95b042715020ebb12d83ea0690db80a8f03d23/greenlet-3.5.6-cp315-cp315t-manylinux_2_39_riscv64.whl", hash = "sha256:520648db8fb92eef7b3e6013f5a6f901cdf0d6685f639c2f7a245879f865bef7", size = 517058, upload-time = "2026-09-14T15:28:44.924Z" },
+    { url = "https://files.pythonhosted.org/packages/89/58/c9275fd0ca195d1d3402931bcce8cfcc74726ff76efb1883d229e6e1a3d7/greenlet-3.5.6-cp315-cp315t-musllinux_1_2_aarch64.whl", hash = "sha256:7f924a5a9d5890649566f2f6682e0d8ad8ca23028bacffbbac36dbd7fd680176", size = 1645988, upload-time = "2026-09-14T15:10:13.758Z" },
+    { url = "https://files.pythonhosted.org/packages/e0/36/b35747582fa4f1a5453f8f3002405dbac788e450cec7674dc2d204b6ccb5/greenlet-3.5.6-cp315-cp315t-musllinux_1_2_x86_64.whl", hash = "sha256:de9923832f2d8c1a5ecd8d7260465a6ca5a86888a0d129e3bd5cf0406d2fc5bf", size = 1702383, upload-time = "2026-09-14T14:35:58.143Z" },
+    { url = "https://files.pythonhosted.org/packages/ed/69/6ec22ac9351e474d2a134d0ff9400dc80362d1c20f0721088ffffdfc205b/greenlet-3.5.6-cp315-cp315t-win_amd64.whl", hash = "sha256:2ab5f42ac6c238eb71770715e6e909ad9a1a92b6c681ccb64cd5a0f07edb953f", size = 331845, upload-time = "2026-09-14T14:27:41.723Z" },
+    { url = "https://files.pythonhosted.org/packages/30/cf/697c051fd534e223461fb8b523890e21a24eeca229cd50624cff6f02fabd/greenlet-3.5.6-cp315-cp315t-win_arm64.whl", hash = "sha256:f9fe868463ec7e1363733af77e38a5fda3e9b63940337048c945d69e0c80ff24", size = 315070, upload-time = "2026-09-14T14:22:21.476Z" },
+]
+
+[[package]]
+name = "playwright"
+version = "1.63.0"
+source = { registry = "https://pypi.org/simple" }
+dependencies = [
+    { name = "greenlet" },
+    { name = "pyee" },
+]
+wheels = [
+    { url = "https://files.pythonhosted.org/packages/19/dd/fbb3d34228ad753bc14464d5f2252585b73367539775a88d0a3949cf5a45/playwright-1.63.0-py3-none-macosx_10_13_x86_64.whl", hash = "sha256:84c540759e8e7f01e690e197e04060f48899d37cea322299f255843273d3385d", size = 44278407, upload-time = "2026-09-15T16:49:06.045Z" },
+    { url = "https://files.pythonhosted.org/packages/f5/9a/948b930b1a8c4ee869e5a139a2b7747caa06aab56a3f09a2f0abdcbda221/playwright-1.63.0-py3-none-macosx_11_0_arm64.whl", hash = "sha256:fd1aa00631d44d55e56e0975bf3f3f285fac4a9fd2813183f0c12a488f1a1b24", size = 42944679, upload-time = "2026-09-15T16:49:10.039Z" },
+    { url = "https://files.pythonhosted.org/packages/94/11/dc5c13fa1602371603acd461be47529c1b3513815d3a0dc98f642c291a10/playwright-1.63.0-py3-none-macosx_11_0_universal2.whl", hash = "sha256:c89fc4736502a1f0fac2c8ca5d10c0cbc1c669f1f4774a2d8507a43140e4d53f", size = 44278410, upload-time = "2026-09-15T16:49:13.861Z" },
+    { url = "https://files.pythonhosted.org/packages/27/9c/103a5037789062bdab27c7dca53f3ca6b075b572ab2cd96eec825b3aec4e/playwright-1.63.0-py3-none-manylinux1_x86_64.whl", hash = "sha256:ad21bc07516b187965a7521c5cf0df0bd657b17482eaad74335272d35a2b07de", size = 48217159, upload-time = "2026-09-15T16:49:17.404Z" },
+    { url = "https://files.pythonhosted.org/packages/f3/82/3d85505284c5a210f2da6c07b8f757524e79d1fba9cfdafe1eafb766ae59/playwright-1.63.0-py3-none-manylinux_2_17_aarch64.manylinux2014_aarch64.whl", hash = "sha256:354e15b29503565fc598b89f16fbe070459343bef9d7498a93e304864000c6a7", size = 47902708, upload-time = "2026-09-15T16:49:21.055Z" },
+    { url = "https://files.pythonhosted.org/packages/69/8d/f74ff6b52751859f4b69caf66aa7d4a3c8d6c1f0c7dc9920da103612ee39/playwright-1.63.0-py3-none-win32.whl", hash = "sha256:660c00c62639e31b16700ba5456b351ddba55bb766b7ce8261223aa34928e482", size = 38606075, upload-time = "2026-09-15T16:49:29.546Z" },
+    { url = "https://files.pythonhosted.org/packages/76/eb/d6b8d92658038e260dbc7dd69fb3fdbe245aac283953de8b50b02bfe5f61/playwright-1.63.0-py3-none-win_amd64.whl", hash = "sha256:2f9a707a6c6c91157ed77bff2b8caeb04b3c8d46e70d585fc134298cbe4b5cc6", size = 38606082, upload-time = "2026-09-15T16:49:32.838Z" },
+    { url = "https://files.pythonhosted.org/packages/be/75/2432b3e3c7c62103b72d4c4cc8b16a56383ada372bbb0d1278591e988f71/playwright-1.63.0-py3-none-win_arm64.whl", hash = "sha256:1e4a3a838ce22fb68ad17193fcd142a19610d9d70fb9966d2239f5dddc0cc05b", size = 34523554, upload-time = "2026-09-15T16:49:36.455Z" },
+]
+
+[[package]]
+name = "pyee"
+version = "13.0.1"
+source = { registry = "https://pypi.org/simple" }
+dependencies = [
+    { name = "typing-extensions" },
+]
+sdist = { url = "https://files.pythonhosted.org/packages/8b/04/e7c1fe4dc78a6fdbfd6c337b1c3732ff543b8a397683ab38378447baa331/pyee-13.0.1.tar.gz", hash = "sha256:0b931f7c14535667ed4c7e0d531716368715e860b988770fc7eb8578d1f67fc8", size = 31655, upload-time = "2026-02-14T21:12:28.044Z" }
+wheels = [
+    { url = "https://files.pythonhosted.org/packages/a0/c4/b4d4827c93ef43c01f599ef31453ccc1c132b353284fc6c87d535c233129/pyee-13.0.1-py3-none-any.whl", hash = "sha256:af2f8fede4171ef667dfded53f96e2ed0d6e6bd7ee3bb46437f77e3b57689228", size = 15659, upload-time = "2026-02-14T21:12:26.263Z" },
+]
+
+[[package]]
+name = "pyyaml"
+version = "6.0.3"
+source = { registry = "https://pypi.org/simple" }
+sdist = { url = "https://files.pythonhosted.org/packages/05/8e/961c0007c59b8dd7729d542c61a4d537767a59645b82a0b521206e1e25c2/pyyaml-6.0.3.tar.gz", hash = "sha256:d76623373421df22fb4cf8817020cbb7ef15c725b9d5e45f17e189bfc384190f", size = 130960, upload-time = "2025-09-25T21:33:16.546Z" }
+wheels = [
+    { url = "https://files.pythonhosted.org/packages/d1/33/422b98d2195232ca1826284a76852ad5a86fe23e31b009c9886b2d0fb8b2/pyyaml-6.0.3-cp312-cp312-macosx_10_13_x86_64.whl", hash = "sha256:7f047e29dcae44602496db43be01ad42fc6f1cc0d8cd6c83d342306c32270196", size = 182063, upload-time = "2025-09-25T21:32:11.445Z" },
+    { url = "https://files.pythonhosted.org/packages/89/a0/6cf41a19a1f2f3feab0e9c0b74134aa2ce6849093d5517a0c550fe37a648/pyyaml-6.0.3-cp312-cp312-macosx_11_0_arm64.whl", hash = "sha256:fc09d0aa354569bc501d4e787133afc08552722d3ab34836a80547331bb5d4a0", size = 173973, upload-time = "2025-09-25T21:32:12.492Z" },
+    { url = "https://files.pythonhosted.org/packages/ed/23/7a778b6bd0b9a8039df8b1b1d80e2e2ad78aa04171592c8a5c43a56a6af4/pyyaml-6.0.3-cp312-cp312-manylinux2014_aarch64.manylinux_2_17_aarch64.manylinux_2_28_aarch64.whl", hash = "sha256:9149cad251584d5fb4981be1ecde53a1ca46c891a79788c0df828d2f166bda28", size = 775116, upload-time = "2025-09-25T21:32:13.652Z" },
+    { url = "https://files.pythonhosted.org/packages/65/30/d7353c338e12baef4ecc1b09e877c1970bd3382789c159b4f89d6a70dc09/pyyaml-6.0.3-cp312-cp312-manylinux2014_s390x.manylinux_2_17_s390x.manylinux_2_28_s390x.whl", hash = "sha256:5fdec68f91a0c6739b380c83b951e2c72ac0197ace422360e6d5a959d8d97b2c", size = 844011, upload-time = "2025-09-25T21:32:15.21Z" },
+    { url = "https://files.pythonhosted.org/packages/8b/9d/b3589d3877982d4f2329302ef98a8026e7f4443c765c46cfecc8858c6b4b/pyyaml-6.0.3-cp312-cp312-manylinux2014_x86_64.manylinux_2_17_x86_64.manylinux_2_28_x86_64.whl", hash = "sha256:ba1cc08a7ccde2d2ec775841541641e4548226580ab850948cbfda66a1befcdc", size = 807870, upload-time = "2025-09-25T21:32:16.431Z" },
+    { url = "https://files.pythonhosted.org/packages/05/c0/b3be26a015601b822b97d9149ff8cb5ead58c66f981e04fedf4e762f4bd4/pyyaml-6.0.3-cp312-cp312-musllinux_1_2_aarch64.whl", hash = "sha256:8dc52c23056b9ddd46818a57b78404882310fb473d63f17b07d5c40421e47f8e", size = 761089, upload-time = "2025-09-25T21:32:17.56Z" },
+    { url = "https://files.pythonhosted.org/packages/be/8e/98435a21d1d4b46590d5459a22d88128103f8da4c2d4cb8f14f2a96504e1/pyyaml-6.0.3-cp312-cp312-musllinux_1_2_x86_64.whl", hash = "sha256:41715c910c881bc081f1e8872880d3c650acf13dfa8214bad49ed4cede7c34ea", size = 790181, upload-time = "2025-09-25T21:32:18.834Z" },
+    { url = "https://files.pythonhosted.org/packages/74/93/7baea19427dcfbe1e5a372d81473250b379f04b1bd3c4c5ff825e2327202/pyyaml-6.0.3-cp312-cp312-win32.whl", hash = "sha256:96b533f0e99f6579b3d4d4995707cf36df9100d67e0c8303a0c55b27b5f99bc5", size = 137658, upload-time = "2025-09-25T21:32:20.209Z" },
+    { url = "https://files.pythonhosted.org/packages/86/bf/899e81e4cce32febab4fb42bb97dcdf66bc135272882d1987881a4b519e9/pyyaml-6.0.3-cp312-cp312-win_amd64.whl", hash = "sha256:5fcd34e47f6e0b794d17de1b4ff496c00986e1c83f7ab2fb8fcfe9616ff7477b", size = 154003, upload-time = "2025-09-25T21:32:21.167Z" },
+    { url = "https://files.pythonhosted.org/packages/1a/08/67bd04656199bbb51dbed1439b7f27601dfb576fb864099c7ef0c3e55531/pyyaml-6.0.3-cp312-cp312-win_arm64.whl", hash = "sha256:64386e5e707d03a7e172c0701abfb7e10f0fb753ee1d773128192742712a98fd", size = 140344, upload-time = "2025-09-25T21:32:22.617Z" },
+    { url = "https://files.pythonhosted.org/packages/d1/11/0fd08f8192109f7169db964b5707a2f1e8b745d4e239b784a5a1dd80d1db/pyyaml-6.0.3-cp313-cp313-macosx_10_13_x86_64.whl", hash = "sha256:8da9669d359f02c0b91ccc01cac4a67f16afec0dac22c2ad09f46bee0697eba8", size = 181669, upload-time = "2025-09-25T21:32:23.673Z" },
+    { url = "https://files.pythonhosted.org/packages/b1/16/95309993f1d3748cd644e02e38b75d50cbc0d9561d21f390a76242ce073f/pyyaml-6.0.3-cp313-cp313-macosx_11_0_arm64.whl", hash = "sha256:2283a07e2c21a2aa78d9c4442724ec1eb15f5e42a723b99cb3d822d48f5f7ad1", size = 173252, upload-time = "2025-09-25T21:32:25.149Z" },
+    { url = "https://files.pythonhosted.org/packages/50/31/b20f376d3f810b9b2371e72ef5adb33879b25edb7a6d072cb7ca0c486398/pyyaml-6.0.3-cp313-cp313-manylinux2014_aarch64.manylinux_2_17_aarch64.manylinux_2_28_aarch64.whl", hash = "sha256:ee2922902c45ae8ccada2c5b501ab86c36525b883eff4255313a253a3160861c", size = 767081, upload-time = "2025-09-25T21:32:26.575Z" },
+    { url = "https://files.pythonhosted.org/packages/49/1e/a55ca81e949270d5d4432fbbd19dfea5321eda7c41a849d443dc92fd1ff7/pyyaml-6.0.3-cp313-cp313-manylinux2014_s390x.manylinux_2_17_s390x.manylinux_2_28_s390x.whl", hash = "sha256:a33284e20b78bd4a18c8c2282d549d10bc8408a2a7ff57653c0cf0b9be0afce5", size = 841159, upload-time = "2025-09-25T21:32:27.727Z" },
+    { url = "https://files.pythonhosted.org/packages/74/27/e5b8f34d02d9995b80abcef563ea1f8b56d20134d8f4e5e81733b1feceb2/pyyaml-6.0.3-cp313-cp313-manylinux2014_x86_64.manylinux_2_17_x86_64.manylinux_2_28_x86_64.whl", hash = "sha256:0f29edc409a6392443abf94b9cf89ce99889a1dd5376d94316ae5145dfedd5d6", size = 801626, upload-time = "2025-09-25T21:32:28.878Z" },
+    { url = "https://files.pythonhosted.org/packages/f9/11/ba845c23988798f40e52ba45f34849aa8a1f2d4af4b798588010792ebad6/pyyaml-6.0.3-cp313-cp313-musllinux_1_2_aarch64.whl", hash = "sha256:f7057c9a337546edc7973c0d3ba84ddcdf0daa14533c2065749c9075001090e6", size = 753613, upload-time = "2025-09-25T21:32:30.178Z" },
+    { url = "https://files.pythonhosted.org/packages/3d/e0/7966e1a7bfc0a45bf0a7fb6b98ea03fc9b8d84fa7f2229e9659680b69ee3/pyyaml-6.0.3-cp313-cp313-musllinux_1_2_x86_64.whl", hash = "sha256:eda16858a3cab07b80edaf74336ece1f986ba330fdb8ee0d6c0d68fe82bc96be", size = 794115, upload-time = "2025-09-25T21:32:31.353Z" },
+    { url = "https://files.pythonhosted.org/packages/de/94/980b50a6531b3019e45ddeada0626d45fa85cbe22300844a7983285bed3b/pyyaml-6.0.3-cp313-cp313-win32.whl", hash = "sha256:d0eae10f8159e8fdad514efdc92d74fd8d682c933a6dd088030f3834bc8e6b26", size = 137427, upload-time = "2025-09-25T21:32:32.58Z" },
+    { url = "https://files.pythonhosted.org/packages/97/c9/39d5b874e8b28845e4ec2202b5da735d0199dbe5b8fb85f91398814a9a46/pyyaml-6.0.3-cp313-cp313-win_amd64.whl", hash = "sha256:79005a0d97d5ddabfeeea4cf676af11e647e41d81c9a7722a193022accdb6b7c", size = 154090, upload-time = "2025-09-25T21:32:33.659Z" },
+    { url = "https://files.pythonhosted.org/packages/73/e8/2bdf3ca2090f68bb3d75b44da7bbc71843b19c9f2b9cb9b0f4ab7a5a4329/pyyaml-6.0.3-cp313-cp313-win_arm64.whl", hash = "sha256:5498cd1645aa724a7c71c8f378eb29ebe23da2fc0d7a08071d89469bf1d2defb", size = 140246, upload-time = "2025-09-25T21:32:34.663Z" },
+    { url = "https://files.pythonhosted.org/packages/9d/8c/f4bd7f6465179953d3ac9bc44ac1a8a3e6122cf8ada906b4f96c60172d43/pyyaml-6.0.3-cp314-cp314-macosx_10_13_x86_64.whl", hash = "sha256:8d1fab6bb153a416f9aeb4b8763bc0f22a5586065f86f7664fc23339fc1c1fac", size = 181814, upload-time = "2025-09-25T21:32:35.712Z" },
+    { url = "https://files.pythonhosted.org/packages/bd/9c/4d95bb87eb2063d20db7b60faa3840c1b18025517ae857371c4dd55a6b3a/pyyaml-6.0.3-cp314-cp314-macosx_11_0_arm64.whl", hash = "sha256:34d5fcd24b8445fadc33f9cf348c1047101756fd760b4dacb5c3e99755703310", size = 173809, upload-time = "2025-09-25T21:32:36.789Z" },
+    { url = "https://files.pythonhosted.org/packages/92/b5/47e807c2623074914e29dabd16cbbdd4bf5e9b2db9f8090fa64411fc5382/pyyaml-6.0.3-cp314-cp314-manylinux2014_aarch64.manylinux_2_17_aarch64.manylinux_2_28_aarch64.whl", hash = "sha256:501a031947e3a9025ed4405a168e6ef5ae3126c59f90ce0cd6f2bfc477be31b7", size = 766454, upload-time = "2025-09-25T21:32:37.966Z" },
+    { url = "https://files.pythonhosted.org/packages/02/9e/e5e9b168be58564121efb3de6859c452fccde0ab093d8438905899a3a483/pyyaml-6.0.3-cp314-cp314-manylinux2014_s390x.manylinux_2_17_s390x.manylinux_2_28_s390x.whl", hash = "sha256:b3bc83488de33889877a0f2543ade9f70c67d66d9ebb4ac959502e12de895788", size = 836355, upload-time = "2025-09-25T21:32:39.178Z" },
+    { url = "https://files.pythonhosted.org/packages/88/f9/16491d7ed2a919954993e48aa941b200f38040928474c9e85ea9e64222c3/pyyaml-6.0.3-cp314-cp314-manylinux2014_x86_64.manylinux_2_17_x86_64.manylinux_2_28_x86_64.whl", hash = "sha256:c458b6d084f9b935061bc36216e8a69a7e293a2f1e68bf956dcd9e6cbcd143f5", size = 794175, upload-time = "2025-09-25T21:32:40.865Z" },
+    { url = "https://files.pythonhosted.org/packages/dd/3f/5989debef34dc6397317802b527dbbafb2b4760878a53d4166579111411e/pyyaml-6.0.3-cp314-cp314-musllinux_1_2_aarch64.whl", hash = "sha256:7c6610def4f163542a622a73fb39f534f8c101d690126992300bf3207eab9764", size = 755228, upload-time = "2025-09-25T21:32:42.084Z" },
+    { url = "https://files.pythonhosted.org/packages/d7/ce/af88a49043cd2e265be63d083fc75b27b6ed062f5f9fd6cdc223ad62f03e/pyyaml-6.0.3-cp314-cp314-musllinux_1_2_x86_64.whl", hash = "sha256:5190d403f121660ce8d1d2c1bb2ef1bd05b5f68533fc5c2ea899bd15f4399b35", size = 789194, upload-time = "2025-09-25T21:32:43.362Z" },
+    { url = "https://files.pythonhosted.org/packages/23/20/bb6982b26a40bb43951265ba29d4c246ef0ff59c9fdcdf0ed04e0687de4d/pyyaml-6.0.3-cp314-cp314-win_amd64.whl", hash = "sha256:4a2e8cebe2ff6ab7d1050ecd59c25d4c8bd7e6f400f5f82b96557ac0abafd0ac", size = 156429, upload-time = "2025-09-25T21:32:57.844Z" },
+    { url = "https://files.pythonhosted.org/packages/f4/f4/a4541072bb9422c8a883ab55255f918fa378ecf083f5b85e87fc2b4eda1b/pyyaml-6.0.3-cp314-cp314-win_arm64.whl", hash = "sha256:93dda82c9c22deb0a405ea4dc5f2d0cda384168e466364dec6255b293923b2f3", size = 143912, upload-time = "2025-09-25T21:32:59.247Z" },
+    { url = "https://files.pythonhosted.org/packages/7c/f9/07dd09ae774e4616edf6cda684ee78f97777bdd15847253637a6f052a62f/pyyaml-6.0.3-cp314-cp314t-macosx_10_13_x86_64.whl", hash = "sha256:02893d100e99e03eda1c8fd5c441d8c60103fd175728e23e431db1b589cf5ab3", size = 189108, upload-time = "2025-09-25T21:32:44.377Z" },
+    { url = "https://files.pythonhosted.org/packages/4e/78/8d08c9fb7ce09ad8c38ad533c1191cf27f7ae1effe5bb9400a46d9437fcf/pyyaml-6.0.3-cp314-cp314t-macosx_11_0_arm64.whl", hash = "sha256:c1ff362665ae507275af2853520967820d9124984e0f7466736aea23d8611fba", size = 183641, upload-time = "2025-09-25T21:32:45.407Z" },
+    { url = "https://files.pythonhosted.org/packages/7b/5b/3babb19104a46945cf816d047db2788bcaf8c94527a805610b0289a01c6b/pyyaml-6.0.3-cp314-cp314t-manylinux2014_aarch64.manylinux_2_17_aarch64.manylinux_2_28_aarch64.whl", hash = "sha256:6adc77889b628398debc7b65c073bcb99c4a0237b248cacaf3fe8a557563ef6c", size = 831901, upload-time = "2025-09-25T21:32:48.83Z" },
+    { url = "https://files.pythonhosted.org/packages/8b/cc/dff0684d8dc44da4d22a13f35f073d558c268780ce3c6ba1b87055bb0b87/pyyaml-6.0.3-cp314-cp314t-manylinux2014_s390x.manylinux_2_17_s390x.manylinux_2_28_s390x.whl", hash = "sha256:a80cb027f6b349846a3bf6d73b5e95e782175e52f22108cfa17876aaeff93702", size = 861132, upload-time = "2025-09-25T21:32:50.149Z" },
+    { url = "https://files.pythonhosted.org/packages/b1/5e/f77dc6b9036943e285ba76b49e118d9ea929885becb0a29ba8a7c75e29fe/pyyaml-6.0.3-cp314-cp314t-manylinux2014_x86_64.manylinux_2_17_x86_64.manylinux_2_28_x86_64.whl", hash = "sha256:00c4bdeba853cc34e7dd471f16b4114f4162dc03e6b7afcc2128711f0eca823c", size = 839261, upload-time = "2025-09-25T21:32:51.808Z" },
+    { url = "https://files.pythonhosted.org/packages/ce/88/a9db1376aa2a228197c58b37302f284b5617f56a5d959fd1763fb1675ce6/pyyaml-6.0.3-cp314-cp314t-musllinux_1_2_aarch64.whl", hash = "sha256:66e1674c3ef6f541c35191caae2d429b967b99e02040f5ba928632d9a7f0f065", size = 805272, upload-time = "2025-09-25T21:32:52.941Z" },
+    { url = "https://files.pythonhosted.org/packages/da/92/1446574745d74df0c92e6aa4a7b0b3130706a4142b2d1a5869f2eaa423c6/pyyaml-6.0.3-cp314-cp314t-musllinux_1_2_x86_64.whl", hash = "sha256:16249ee61e95f858e83976573de0f5b2893b3677ba71c9dd36b9cf8be9ac6d65", size = 829923, upload-time = "2025-09-25T21:32:54.537Z" },
+    { url = "https://files.pythonhosted.org/packages/f0/7a/1c7270340330e575b92f397352af856a8c06f230aa3e76f86b39d01b416a/pyyaml-6.0.3-cp314-cp314t-win_amd64.whl", hash = "sha256:4ad1906908f2f5ae4e5a8ddfce73c320c2a1429ec52eafd27138b7f1cbe341c9", size = 174062, upload-time = "2025-09-25T21:32:55.767Z" },
+    { url = "https://files.pythonhosted.org/packages/f1/12/de94a39c2ef588c7e6455cfbe7343d3b2dc9d6b6b2f40c4c6565744c873d/pyyaml-6.0.3-cp314-cp314t-win_arm64.whl", hash = "sha256:ebc55a14a21cb14062aa4162f906cd962b28e2e9ea38f9b4391244cd8de4ae0b", size = 149341, upload-time = "2025-09-25T21:32:56.828Z" },
+]
+
+[[package]]
+name = "typing-extensions"
+version = "4.16.0"
+source = { registry = "https://pypi.org/simple" }
+sdist = { url = "https://files.pythonhosted.org/packages/f6/cc/6253133b5bb138fc3306cebfbda2c520f545d36b5be2c7255cc528bb45d6/typing_extensions-4.16.0.tar.gz", hash = "sha256:dc983d19a509c94dba722ee6abd33940f7c05a89e243c47e907eb4db6f1a43e5", size = 113555, upload-time = "2026-07-02T08:40:05.92Z" }
+wheels = [
+    { url = "https://files.pythonhosted.org/packages/49/d3/b8441a820a491ddfc024b0b0cf0393375b75ea13866d9c66727e54c2fc80/typing_extensions-4.16.0-py3-none-any.whl", hash = "sha256:481caa481374e813c1b176ada14e97f1f67a4539ce9cfeb3f350d78d6370c2e8", size = 45571, upload-time = "2026-07-02T08:40:04.659Z" },
+]
diff --git a/scripts/test_flows.py b/scripts/test_flows.py
index 1f47cfd..d46a713 100644
--- a/scripts/test_flows.py
+++ b/scripts/test_flows.py
@@ -14,6 +14,13 @@
 #    ./scripts/test_flows.py --engine-repo ../dfe-engine
 #    DFE_ENGINE_REPO=../dfe-engine ./scripts/test_flows.py
 
+# /// script
+# requires-python = ">=3.12"
+# dependencies = [
+#     "pyyaml==6.0.3",
+# ]
+# ///
+
 """The flow shapes, on the compose stack, over localhost ports.
 
 The fixtures and the assertions live in dfe-engine (``tests/e2e/flows``) and are
diff --git a/scripts/test_flows.py.lock b/scripts/test_flows.py.lock
new file mode 100644
index 0000000..dd4a33c
--- /dev/null
+++ b/scripts/test_flows.py.lock
@@ -0,0 +1,52 @@
+version = 1
+revision = 5
+requires-python = ">=3.12"
+
+[manifest]
+requirements = [{ name = "pyyaml", specifier = "==6.0.3" }]
+
+[[package]]
+name = "pyyaml"
+version = "6.0.3"
+source = { registry = "https://pypi.org/simple" }
+sdist = { url = "https://files.pythonhosted.org/packages/05/8e/961c0007c59b8dd7729d542c61a4d537767a59645b82a0b521206e1e25c2/pyyaml-6.0.3.tar.gz", hash = "sha256:d76623373421df22fb4cf8817020cbb7ef15c725b9d5e45f17e189bfc384190f", size = 130960, upload-time = "2025-09-25T21:33:16.546Z" }
+wheels = [
+    { url = "https://files.pythonhosted.org/packages/d1/33/422b98d2195232ca1826284a76852ad5a86fe23e31b009c9886b2d0fb8b2/pyyaml-6.0.3-cp312-cp312-macosx_10_13_x86_64.whl", hash = "sha256:7f047e29dcae44602496db43be01ad42fc6f1cc0d8cd6c83d342306c32270196", size = 182063, upload-time = "2025-09-25T21:32:11.445Z" },
+    { url = "https://files.pythonhosted.org/packages/89/a0/6cf41a19a1f2f3feab0e9c0b74134aa2ce6849093d5517a0c550fe37a648/pyyaml-6.0.3-cp312-cp312-macosx_11_0_arm64.whl", hash = "sha256:fc09d0aa354569bc501d4e787133afc08552722d3ab34836a80547331bb5d4a0", size = 173973, upload-time = "2025-09-25T21:32:12.492Z" },
+    { url = "https://files.pythonhosted.org/packages/ed/23/7a778b6bd0b9a8039df8b1b1d80e2e2ad78aa04171592c8a5c43a56a6af4/pyyaml-6.0.3-cp312-cp312-manylinux2014_aarch64.manylinux_2_17_aarch64.manylinux_2_28_aarch64.whl", hash = "sha256:9149cad251584d5fb4981be1ecde53a1ca46c891a79788c0df828d2f166bda28", size = 775116, upload-time = "2025-09-25T21:32:13.652Z" },
+    { url = "https://files.pythonhosted.org/packages/65/30/d7353c338e12baef4ecc1b09e877c1970bd3382789c159b4f89d6a70dc09/pyyaml-6.0.3-cp312-cp312-manylinux2014_s390x.manylinux_2_17_s390x.manylinux_2_28_s390x.whl", hash = "sha256:5fdec68f91a0c6739b380c83b951e2c72ac0197ace422360e6d5a959d8d97b2c", size = 844011, upload-time = "2025-09-25T21:32:15.21Z" },
+    { url = "https://files.pythonhosted.org/packages/8b/9d/b3589d3877982d4f2329302ef98a8026e7f4443c765c46cfecc8858c6b4b/pyyaml-6.0.3-cp312-cp312-manylinux2014_x86_64.manylinux_2_17_x86_64.manylinux_2_28_x86_64.whl", hash = "sha256:ba1cc08a7ccde2d2ec775841541641e4548226580ab850948cbfda66a1befcdc", size = 807870, upload-time = "2025-09-25T21:32:16.431Z" },
+    { url = "https://files.pythonhosted.org/packages/05/c0/b3be26a015601b822b97d9149ff8cb5ead58c66f981e04fedf4e762f4bd4/pyyaml-6.0.3-cp312-cp312-musllinux_1_2_aarch64.whl", hash = "sha256:8dc52c23056b9ddd46818a57b78404882310fb473d63f17b07d5c40421e47f8e", size = 761089, upload-time = "2025-09-25T21:32:17.56Z" },
+    { url = "https://files.pythonhosted.org/packages/be/8e/98435a21d1d4b46590d5459a22d88128103f8da4c2d4cb8f14f2a96504e1/pyyaml-6.0.3-cp312-cp312-musllinux_1_2_x86_64.whl", hash = "sha256:41715c910c881bc081f1e8872880d3c650acf13dfa8214bad49ed4cede7c34ea", size = 790181, upload-time = "2025-09-25T21:32:18.834Z" },
+    { url = "https://files.pythonhosted.org/packages/74/93/7baea19427dcfbe1e5a372d81473250b379f04b1bd3c4c5ff825e2327202/pyyaml-6.0.3-cp312-cp312-win32.whl", hash = "sha256:96b533f0e99f6579b3d4d4995707cf36df9100d67e0c8303a0c55b27b5f99bc5", size = 137658, upload-time = "2025-09-25T21:32:20.209Z" },
+    { url = "https://files.pythonhosted.org/packages/86/bf/899e81e4cce32febab4fb42bb97dcdf66bc135272882d1987881a4b519e9/pyyaml-6.0.3-cp312-cp312-win_amd64.whl", hash = "sha256:5fcd34e47f6e0b794d17de1b4ff496c00986e1c83f7ab2fb8fcfe9616ff7477b", size = 154003, upload-time = "2025-09-25T21:32:21.167Z" },
+    { url = "https://files.pythonhosted.org/packages/1a/08/67bd04656199bbb51dbed1439b7f27601dfb576fb864099c7ef0c3e55531/pyyaml-6.0.3-cp312-cp312-win_arm64.whl", hash = "sha256:64386e5e707d03a7e172c0701abfb7e10f0fb753ee1d773128192742712a98fd", size = 140344, upload-time = "2025-09-25T21:32:22.617Z" },
+    { url = "https://files.pythonhosted.org/packages/d1/11/0fd08f8192109f7169db964b5707a2f1e8b745d4e239b784a5a1dd80d1db/pyyaml-6.0.3-cp313-cp313-macosx_10_13_x86_64.whl", hash = "sha256:8da9669d359f02c0b91ccc01cac4a67f16afec0dac22c2ad09f46bee0697eba8", size = 181669, upload-time = "2025-09-25T21:32:23.673Z" },
+    { url = "https://files.pythonhosted.org/packages/b1/16/95309993f1d3748cd644e02e38b75d50cbc0d9561d21f390a76242ce073f/pyyaml-6.0.3-cp313-cp313-macosx_11_0_arm64.whl", hash = "sha256:2283a07e2c21a2aa78d9c4442724ec1eb15f5e42a723b99cb3d822d48f5f7ad1", size = 173252, upload-time = "2025-09-25T21:32:25.149Z" },
+    { url = "https://files.pythonhosted.org/packages/50/31/b20f376d3f810b9b2371e72ef5adb33879b25edb7a6d072cb7ca0c486398/pyyaml-6.0.3-cp313-cp313-manylinux2014_aarch64.manylinux_2_17_aarch64.manylinux_2_28_aarch64.whl", hash = "sha256:ee2922902c45ae8ccada2c5b501ab86c36525b883eff4255313a253a3160861c", size = 767081, upload-time = "2025-09-25T21:32:26.575Z" },
+    { url = "https://files.pythonhosted.org/packages/49/1e/a55ca81e949270d5d4432fbbd19dfea5321eda7c41a849d443dc92fd1ff7/pyyaml-6.0.3-cp313-cp313-manylinux2014_s390x.manylinux_2_17_s390x.manylinux_2_28_s390x.whl", hash = "sha256:a33284e20b78bd4a18c8c2282d549d10bc8408a2a7ff57653c0cf0b9be0afce5", size = 841159, upload-time = "2025-09-25T21:32:27.727Z" },
+    { url = "https://files.pythonhosted.org/packages/74/27/e5b8f34d02d9995b80abcef563ea1f8b56d20134d8f4e5e81733b1feceb2/pyyaml-6.0.3-cp313-cp313-manylinux2014_x86_64.manylinux_2_17_x86_64.manylinux_2_28_x86_64.whl", hash = "sha256:0f29edc409a6392443abf94b9cf89ce99889a1dd5376d94316ae5145dfedd5d6", size = 801626, upload-time = "2025-09-25T21:32:28.878Z" },
+    { url = "https://files.pythonhosted.org/packages/f9/11/ba845c23988798f40e52ba45f34849aa8a1f2d4af4b798588010792ebad6/pyyaml-6.0.3-cp313-cp313-musllinux_1_2_aarch64.whl", hash = "sha256:f7057c9a337546edc7973c0d3ba84ddcdf0daa14533c2065749c9075001090e6", size = 753613, upload-time = "2025-09-25T21:32:30.178Z" },
+    { url = "https://files.pythonhosted.org/packages/3d/e0/7966e1a7bfc0a45bf0a7fb6b98ea03fc9b8d84fa7f2229e9659680b69ee3/pyyaml-6.0.3-cp313-cp313-musllinux_1_2_x86_64.whl", hash = "sha256:eda16858a3cab07b80edaf74336ece1f986ba330fdb8ee0d6c0d68fe82bc96be", size = 794115, upload-time = "2025-09-25T21:32:31.353Z" },
+    { url = "https://files.pythonhosted.org/packages/de/94/980b50a6531b3019e45ddeada0626d45fa85cbe22300844a7983285bed3b/pyyaml-6.0.3-cp313-cp313-win32.whl", hash = "sha256:d0eae10f8159e8fdad514efdc92d74fd8d682c933a6dd088030f3834bc8e6b26", size = 137427, upload-time = "2025-09-25T21:32:32.58Z" },
+    { url = "https://files.pythonhosted.org/packages/97/c9/39d5b874e8b28845e4ec2202b5da735d0199dbe5b8fb85f91398814a9a46/pyyaml-6.0.3-cp313-cp313-win_amd64.whl", hash = "sha256:79005a0d97d5ddabfeeea4cf676af11e647e41d81c9a7722a193022accdb6b7c", size = 154090, upload-time = "2025-09-25T21:32:33.659Z" },
+    { url = "https://files.pythonhosted.org/packages/73/e8/2bdf3ca2090f68bb3d75b44da7bbc71843b19c9f2b9cb9b0f4ab7a5a4329/pyyaml-6.0.3-cp313-cp313-win_arm64.whl", hash = "sha256:5498cd1645aa724a7c71c8f378eb29ebe23da2fc0d7a08071d89469bf1d2defb", size = 140246, upload-time = "2025-09-25T21:32:34.663Z" },
+    { url = "https://files.pythonhosted.org/packages/9d/8c/f4bd7f6465179953d3ac9bc44ac1a8a3e6122cf8ada906b4f96c60172d43/pyyaml-6.0.3-cp314-cp314-macosx_10_13_x86_64.whl", hash = "sha256:8d1fab6bb153a416f9aeb4b8763bc0f22a5586065f86f7664fc23339fc1c1fac", size = 181814, upload-time = "2025-09-25T21:32:35.712Z" },
+    { url = "https://files.pythonhosted.org/packages/bd/9c/4d95bb87eb2063d20db7b60faa3840c1b18025517ae857371c4dd55a6b3a/pyyaml-6.0.3-cp314-cp314-macosx_11_0_arm64.whl", hash = "sha256:34d5fcd24b8445fadc33f9cf348c1047101756fd760b4dacb5c3e99755703310", size = 173809, upload-time = "2025-09-25T21:32:36.789Z" },
+    { url = "https://files.pythonhosted.org/packages/92/b5/47e807c2623074914e29dabd16cbbdd4bf5e9b2db9f8090fa64411fc5382/pyyaml-6.0.3-cp314-cp314-manylinux2014_aarch64.manylinux_2_17_aarch64.manylinux_2_28_aarch64.whl", hash = "sha256:501a031947e3a9025ed4405a168e6ef5ae3126c59f90ce0cd6f2bfc477be31b7", size = 766454, upload-time = "2025-09-25T21:32:37.966Z" },
+    { url = "https://files.pythonhosted.org/packages/02/9e/e5e9b168be58564121efb3de6859c452fccde0ab093d8438905899a3a483/pyyaml-6.0.3-cp314-cp314-manylinux2014_s390x.manylinux_2_17_s390x.manylinux_2_28_s390x.whl", hash = "sha256:b3bc83488de33889877a0f2543ade9f70c67d66d9ebb4ac959502e12de895788", size = 836355, upload-time = "2025-09-25T21:32:39.178Z" },
+    { url = "https://files.pythonhosted.org/packages/88/f9/16491d7ed2a919954993e48aa941b200f38040928474c9e85ea9e64222c3/pyyaml-6.0.3-cp314-cp314-manylinux2014_x86_64.manylinux_2_17_x86_64.manylinux_2_28_x86_64.whl", hash = "sha256:c458b6d084f9b935061bc36216e8a69a7e293a2f1e68bf956dcd9e6cbcd143f5", size = 794175, upload-time = "2025-09-25T21:32:40.865Z" },
+    { url = "https://files.pythonhosted.org/packages/dd/3f/5989debef34dc6397317802b527dbbafb2b4760878a53d4166579111411e/pyyaml-6.0.3-cp314-cp314-musllinux_1_2_aarch64.whl", hash = "sha256:7c6610def4f163542a622a73fb39f534f8c101d690126992300bf3207eab9764", size = 755228, upload-time = "2025-09-25T21:32:42.084Z" },
+    { url = "https://files.pythonhosted.org/packages/d7/ce/af88a49043cd2e265be63d083fc75b27b6ed062f5f9fd6cdc223ad62f03e/pyyaml-6.0.3-cp314-cp314-musllinux_1_2_x86_64.whl", hash = "sha256:5190d403f121660ce8d1d2c1bb2ef1bd05b5f68533fc5c2ea899bd15f4399b35", size = 789194, upload-time = "2025-09-25T21:32:43.362Z" },
+    { url = "https://files.pythonhosted.org/packages/23/20/bb6982b26a40bb43951265ba29d4c246ef0ff59c9fdcdf0ed04e0687de4d/pyyaml-6.0.3-cp314-cp314-win_amd64.whl", hash = "sha256:4a2e8cebe2ff6ab7d1050ecd59c25d4c8bd7e6f400f5f82b96557ac0abafd0ac", size = 156429, upload-time = "2025-09-25T21:32:57.844Z" },
+    { url = "https://files.pythonhosted.org/packages/f4/f4/a4541072bb9422c8a883ab55255f918fa378ecf083f5b85e87fc2b4eda1b/pyyaml-6.0.3-cp314-cp314-win_arm64.whl", hash = "sha256:93dda82c9c22deb0a405ea4dc5f2d0cda384168e466364dec6255b293923b2f3", size = 143912, upload-time = "2025-09-25T21:32:59.247Z" },
+    { url = "https://files.pythonhosted.org/packages/7c/f9/07dd09ae774e4616edf6cda684ee78f97777bdd15847253637a6f052a62f/pyyaml-6.0.3-cp314-cp314t-macosx_10_13_x86_64.whl", hash = "sha256:02893d100e99e03eda1c8fd5c441d8c60103fd175728e23e431db1b589cf5ab3", size = 189108, upload-time = "2025-09-25T21:32:44.377Z" },
+    { url = "https://files.pythonhosted.org/packages/4e/78/8d08c9fb7ce09ad8c38ad533c1191cf27f7ae1effe5bb9400a46d9437fcf/pyyaml-6.0.3-cp314-cp314t-macosx_11_0_arm64.whl", hash = "sha256:c1ff362665ae507275af2853520967820d9124984e0f7466736aea23d8611fba", size = 183641, upload-time = "2025-09-25T21:32:45.407Z" },
+    { url = "https://files.pythonhosted.org/packages/7b/5b/3babb19104a46945cf816d047db2788bcaf8c94527a805610b0289a01c6b/pyyaml-6.0.3-cp314-cp314t-manylinux2014_aarch64.manylinux_2_17_aarch64.manylinux_2_28_aarch64.whl", hash = "sha256:6adc77889b628398debc7b65c073bcb99c4a0237b248cacaf3fe8a557563ef6c", size = 831901, upload-time = "2025-09-25T21:32:48.83Z" },
+    { url = "https://files.pythonhosted.org/packages/8b/cc/dff0684d8dc44da4d22a13f35f073d558c268780ce3c6ba1b87055bb0b87/pyyaml-6.0.3-cp314-cp314t-manylinux2014_s390x.manylinux_2_17_s390x.manylinux_2_28_s390x.whl", hash = "sha256:a80cb027f6b349846a3bf6d73b5e95e782175e52f22108cfa17876aaeff93702", size = 861132, upload-time = "2025-09-25T21:32:50.149Z" },
+    { url = "https://files.pythonhosted.org/packages/b1/5e/f77dc6b9036943e285ba76b49e118d9ea929885becb0a29ba8a7c75e29fe/pyyaml-6.0.3-cp314-cp314t-manylinux2014_x86_64.manylinux_2_17_x86_64.manylinux_2_28_x86_64.whl", hash = "sha256:00c4bdeba853cc34e7dd471f16b4114f4162dc03e6b7afcc2128711f0eca823c", size = 839261, upload-time = "2025-09-25T21:32:51.808Z" },
+    { url = "https://files.pythonhosted.org/packages/ce/88/a9db1376aa2a228197c58b37302f284b5617f56a5d959fd1763fb1675ce6/pyyaml-6.0.3-cp314-cp314t-musllinux_1_2_aarch64.whl", hash = "sha256:66e1674c3ef6f541c35191caae2d429b967b99e02040f5ba928632d9a7f0f065", size = 805272, upload-time = "2025-09-25T21:32:52.941Z" },
+    { url = "https://files.pythonhosted.org/packages/da/92/1446574745d74df0c92e6aa4a7b0b3130706a4142b2d1a5869f2eaa423c6/pyyaml-6.0.3-cp314-cp314t-musllinux_1_2_x86_64.whl", hash = "sha256:16249ee61e95f858e83976573de0f5b2893b3677ba71c9dd36b9cf8be9ac6d65", size = 829923, upload-time = "2025-09-25T21:32:54.537Z" },
+    { url = "https://files.pythonhosted.org/packages/f0/7a/1c7270340330e575b92f397352af856a8c06f230aa3e76f86b39d01b416a/pyyaml-6.0.3-cp314-cp314t-win_amd64.whl", hash = "sha256:4ad1906908f2f5ae4e5a8ddfce73c320c2a1429ec52eafd27138b7f1cbe341c9", size = 174062, upload-time = "2025-09-25T21:32:55.767Z" },
+    { url = "https://files.pythonhosted.org/packages/f1/12/de94a39c2ef588c7e6455cfbe7343d3b2dc9d6b6b2f40c4c6565744c873d/pyyaml-6.0.3-cp314-cp314t-win_arm64.whl", hash = "sha256:ebc55a14a21cb14062aa4162f906cd962b28e2e9ea38f9b4391244cd8de4ae0b", size = 149341, upload-time = "2025-09-25T21:32:56.828Z" },
+]
diff --git a/scripts/tests/test_ingest_send.py b/scripts/tests/test_ingest_send.py
new file mode 100644
index 0000000..c782060
--- /dev/null
+++ b/scripts/tests/test_ingest_send.py
@@ -0,0 +1,83 @@
+#  Project:      dfe-docker
+#  File:         tests/test_ingest_send.py
+#  Purpose:      Assert the e2e suite's data file is sent concurrently, each answer kept
+#  Language:     Python
+#
+#  License:      BUSL-1.1
+#  Copyright:    (c) 2026 HYPERI PTY LIMITED
+
+"""The receiver holds each answer until the next hop has the record.
+
+A stand-in receiver that holds every request for a fixed time shows the cost:
+one sender at a time pays the hold per event, concurrent senders share it.
+"""
+
+import threading
+import time
+from http.server import BaseHTTPRequestHandler, ThreadingHTTPServer
+
+import pytest
+
+import _pipeline
+
+HOLD_SECONDS = 0.2
+EVENTS = 10
+
+
+class _HoldingReceiver(BaseHTTPRequestHandler):
+    """Answers each POST after HOLD_SECONDS, 503 for a body asking to be refused."""
+
+    def do_POST(self) -> None:
+        body = self.rfile.read(int(self.headers["Content-Length"]))
+        time.sleep(HOLD_SECONDS)
+        self.send_response(503 if b"refuse" in body else 200)
+        self.end_headers()
+
+    def log_message(self, *args) -> None:
+        return
+
+
+@pytest.fixture
+def receiver_url():
+    server = ThreadingHTTPServer(("127.0.0.1", 0), _HoldingReceiver)
+    thread = threading.Thread(target=server.serve_forever, daemon=True)
+    thread.start()
+    try:
+        yield f"http://127.0.0.1:{server.server_address[1]}/ingest"
+    finally:
+        server.shutdown()
+        server.server_close()
+
+
+def _timed(url: str, workers: int) -> tuple[list[int], float]:
+    bodies = [f'{{"n": {n}}}' for n in range(EVENTS)]
+    started = time.monotonic()
+    statuses = _pipeline.post_all(url, bodies, workers=workers)
+    return statuses, time.monotonic() - started
+
+
+def test_one_sender_at_a_time_pays_the_hold_per_event(receiver_url: str) -> None:
+    statuses, elapsed = _timed(receiver_url, workers=1)
+
+    assert statuses == [200] * EVENTS
+    assert elapsed >= EVENTS * HOLD_SECONDS
+
+
+def test_concurrent_senders_share_the_hold(receiver_url: str) -> None:
+    statuses, elapsed = _timed(receiver_url, workers=EVENTS)
+
+    assert statuses == [200] * EVENTS
+    assert elapsed < EVENTS * HOLD_SECONDS / 2
+
+
+def test_each_answer_stays_with_its_own_request(receiver_url: str) -> None:
+    bodies = ['{"n": 0}', '{"refuse": 1}', '{"n": 2}']
+
+    assert _pipeline.post_all(receiver_url, bodies, workers=3) == [200, 503, 200]
+
+
+def test_a_request_nothing_answers_reports_status_zero() -> None:
+    with ThreadingHTTPServer(("127.0.0.1", 0), _HoldingReceiver) as closed:
+        port = closed.server_address[1]
+
+    assert _pipeline.post_all(f"http://127.0.0.1:{port}/", ["{}"], workers=1) == [0]
diff --git a/scripts/tests/test_post.py b/scripts/tests/test_post.py
index 6fd7e12..b90c770 100644
--- a/scripts/tests/test_post.py
+++ b/scripts/tests/test_post.py
@@ -938,3 +938,123 @@ def test_a_stack_without_the_runner_needs_no_runner_password(
     monkeypatch.delenv(_RUNNER_PASSWORD_KEY, raising=False)
 
     assert post._weak_secrets() == []
+
+
+# ClickHouse 26.3's answer to a lightweight DELETE on a table with a projection.
+_PROJECTION_REFUSAL = (
+    "Code: 344. DB::Exception: DELETE query is not allowed for table dfe.main "
+    "because as it has projections and setting lightweight_mutation_projection_mode "
+    "is set to THROW. User should change lightweight_mutation_projection_mode OR "
+    "drop all the projections manually before running the query. "
+    "(SUPPORT_IS_DISABLED) (version 26.3.42.3 (official build))"
+)
+
+
+class _ClickHouse:
+    """A stand-in ClickHouse whose marked rows go once a delete is accepted and lands."""
+
+    def __init__(
+        self, *, refuse_lightweight: str = "", rows: int = 3, deletes_land: bool = True
+    ) -> None:
+        self.refuse_lightweight = refuse_lightweight
+        self.rows = rows
+        self.deletes_land = deletes_land
+        self.statements: list[str] = []
+
+    def execute(self, sql: str, *, timeout: int) -> tuple[bool, str]:
+        self.statements.append(sql)
+        if sql.startswith("DELETE") and self.refuse_lightweight:
+            return False, self.refuse_lightweight
+        if self.deletes_land:
+            self.rows = 0
+        return True, ""
+
+    def count(self, sql: str, **kwargs) -> int:
+        return self.rows
+
+
+def _stub_clickhouse(monkeypatch: pytest.MonkeyPatch, clickhouse: _ClickHouse) -> None:
+    monkeypatch.setattr(post, "ch_execute", clickhouse.execute)
+    monkeypatch.setattr(post, "ch_int", clickhouse.count)
+    monkeypatch.setattr(post, "ch_query", lambda sql: "")
+    monkeypatch.setattr(post, "CLEANUP_TIMEOUT_SECONDS", 0.0)
+
+
+def test_a_table_with_projections_is_cleaned_by_a_mutation(
+    monkeypatch: pytest.MonkeyPatch, capsys: pytest.CaptureFixture
+) -> None:
+    clickhouse = _ClickHouse(refuse_lightweight=_PROJECTION_REFUSAL)
+    _stub_clickhouse(monkeypatch, clickhouse)
+
+    post._cleanup("dfe", "main", "post-1-abcd")
+
+    assert [sql.split()[0] for sql in clickhouse.statements] == ["DELETE", "ALTER"]
+    assert clickhouse.statements[1].startswith("ALTER TABLE dfe.main DELETE WHERE ")
+    assert "'post-1-abcd'" in clickhouse.statements[1]
+    assert "by mutation" in capsys.readouterr().err
+
+
+def test_a_table_without_projections_takes_the_lightweight_delete(
+    monkeypatch: pytest.MonkeyPatch, capsys: pytest.CaptureFixture
+) -> None:
+    clickhouse = _ClickHouse()
+    _stub_clickhouse(monkeypatch, clickhouse)
+
+    post._cleanup("dfe", "main", "post-1-abcd")
+
+    assert len(clickhouse.statements) == 1
+    assert clickhouse.statements[0].startswith("DELETE FROM dfe.main WHERE ")
+    assert "by lightweight DELETE" in capsys.readouterr().err
+
+
+def test_any_other_refusal_is_reported_and_not_retried_as_a_mutation(
+    monkeypatch: pytest.MonkeyPatch, capsys: pytest.CaptureFixture
+) -> None:
+    clickhouse = _ClickHouse(
+        refuse_lightweight="Code: 497. DB::Exception: default: Not enough privileges."
+    )
+    _stub_clickhouse(monkeypatch, clickhouse)
+
+    post._cleanup("dfe", "main", "post-1-abcd")
+
+    assert len(clickhouse.statements) == 1
+    assert "Not enough privileges" in capsys.readouterr().err
+
+
+def test_rows_still_there_at_the_deadline_are_reported(
+    monkeypatch: pytest.MonkeyPatch, capsys: pytest.CaptureFixture
+) -> None:
+    clickhouse = _ClickHouse(refuse_lightweight=_PROJECTION_REFUSAL, deletes_land=False)
+    _stub_clickhouse(monkeypatch, clickhouse)
+
+    post._cleanup("dfe", "main", "post-1-abcd")
+
+    assert "3 synthetic row(s) tagged post-1-abcd remain" in capsys.readouterr().err
+
+
+def test_no_marked_row_means_nothing_is_deleted(
+    monkeypatch: pytest.MonkeyPatch,
+) -> None:
+    clickhouse = _ClickHouse(rows=0)
+    _stub_clickhouse(monkeypatch, clickhouse)
+
+    post._cleanup("dfe", "main", "post-1-abcd")
+
+    assert clickhouse.statements == []
+
+
+def test_the_rows_are_deleted_after_the_console_reads_them_back(
+    monkeypatch: pytest.MonkeyPatch,
+) -> None:
+    calls = _stub_claims(monkeypatch)
+    _stub_main(monkeypatch)
+    monkeypatch.setattr(
+        post,
+        "_ingest_target",
+        lambda *, table: ("dfe-receiver", "http://ingest/ingest"),
+    )
+    monkeypatch.setattr(post, "_cleanup", lambda *args: calls.append("_cleanup"))
+
+    assert post.main() == 0
+    assert calls[-1] == "_cleanup"
+    assert calls.index("_verify_ui_query") < calls.index("_cleanup")
diff --git a/scripts/tests/test_script_locks.py b/scripts/tests/test_script_locks.py
new file mode 100644
index 0000000..c843d09
--- /dev/null
+++ b/scripts/tests/test_script_locks.py
@@ -0,0 +1,98 @@
+#  Project:      dfe-docker
+#  File:         tests/test_script_locks.py
+#  Purpose:      Assert every inline-metadata script is pinned exactly and locked to those pins
+#  Language:     Python
+#
+#  License:      BUSL-1.1
+#  Copyright:    (c) 2026 HYPERI PTY LIMITED
+
+"""The scripts that declare packages inline run with `uv run --locked`.
+
+So each one needs a lock beside it that records exactly the pins it declares,
+and `make check-locks` has to check it. A script that gains inline metadata, or a
+pin that moves without a relock, fails here without needing uv.
+"""
+
+import re
+import tomllib
+from pathlib import Path
+
+import pytest
+
+from _common import REPO_ROOT
+
+SCRIPTS_DIR = REPO_ROOT / "scripts"
+# The reference expression from the inline script metadata specification.
+METADATA_BLOCK = re.compile(
+    r"(?m)^# /// (?P<type>[a-zA-Z0-9-]+)$\s(?P<content>(^#(| .*)$\s)+)^# ///$"
+)
+REQUIREMENT = re.compile(r"^(?P<name>[A-Za-z0-9._-]+)\s*(?P<specifier>.*)$")
+
+
+def _metadata(path: Path) -> dict | None:
+    for block in METADATA_BLOCK.finditer(path.read_text(encoding="utf-8")):
+        if block.group("type") == "script":
+            lines = block.group("content").splitlines(keepends=True)
+            return tomllib.loads(
+                "".join(
+                    line[2:] if line.startswith("# ") else line[1:] for line in lines
+                )
+            )
+    return None
+
+
+def _normalised(name: str) -> str:
+    return re.sub(r"[-_.]+", "-", name).lower()
+
+
+SCRIPTS = sorted(path for path in SCRIPTS_DIR.glob("*.py") if _metadata(path))
+
+
+def test_the_e2e_and_flow_scripts_declare_their_packages() -> None:
+    assert [path.name for path in SCRIPTS] == ["test_e2e.py", "test_flows.py"]
+
+
+@pytest.mark.parametrize("script", SCRIPTS, ids=lambda path: path.name)
+def test_each_pin_is_an_exact_version(script: Path) -> None:
+    for dependency in _metadata(script)["dependencies"]:
+        assert REQUIREMENT.match(dependency)["specifier"].startswith("=="), dependency
+
+
+@pytest.mark.parametrize("script", SCRIPTS, ids=lambda path: path.name)
+def test_the_lock_records_exactly_the_scripts_pins(script: Path) -> None:
+    lock_path = script.with_name(f"{script.name}.lock")
+    assert lock_path.is_file(), f"no lock: run `uv lock --script scripts/{script.name}`"
+    lock = tomllib.loads(lock_path.read_text(encoding="utf-8"))
+    metadata = _metadata(script)
+
+    declared = {
+        (_normalised(match["name"]), match["specifier"].replace(" ", ""))
+        for match in map(REQUIREMENT.match, metadata["dependencies"])
+    }
+    locked = {
+        (_normalised(entry["name"]), entry.get("specifier", ""))
+        for entry in lock["manifest"]["requirements"]
+    }
+
+    assert locked == declared
+    assert lock["requires-python"] == metadata["requires-python"]
+
+
+@pytest.mark.parametrize("script", SCRIPTS, ids=lambda path: path.name)
+def test_every_file_in_the_lock_carries_a_hash(script: Path) -> None:
+    lock = tomllib.loads(
+        script.with_name(f"{script.name}.lock").read_text(encoding="utf-8")
+    )
+    for package in lock["package"]:
+        files = [package.get("sdist") or {}, *(package.get("wheels") or [])]
+        assert all(
+            entry.get("hash", "").startswith("sha256:") for entry in files if entry
+        )
+
+
+@pytest.mark.parametrize("script", SCRIPTS, ids=lambda path: path.name)
+def test_make_check_locks_checks_each_script(script: Path) -> None:
+    makefile = (REPO_ROOT / "Makefile").read_text(encoding="utf-8")
+
+    assert f"lock --check --script scripts/{script.name}" in makefile
+    assert f"run --locked --script ./scripts/{script.name}" in makefile
diff --git a/scripts/tests/test_stack_state.py b/scripts/tests/test_stack_state.py
new file mode 100644
index 0000000..ba55739
--- /dev/null
+++ b/scripts/tests/test_stack_state.py
@@ -0,0 +1,201 @@
+#  Project:      dfe-docker
+#  File:         tests/test_stack_state.py
+#  Purpose:      Assert how the e2e suite reads a stack and plans to start it again
+#  Language:     Python
+#
+#  License:      BUSL-1.1
+#  Copyright:    (c) 2026 HYPERI PTY LIMITED
+
+"""The e2e suite stops every service, so it must put back exactly what it found.
+
+Driven from `docker inspect` documents shaped as docker writes them: which
+containers come back, from which compose files, and when the project counts as
+different from how it was found.
+"""
+
+import pytest
+
+import _stack_state
+
+_FILES = "/opt/dfe/docker-compose.yml,/opt/dfe/docker-compose.tls.yml"
+
+
+def _document(
+    service: str,
+    *,
+    running: bool = True,
+    exit_code: int = 0,
+    restart: str = "unless-stopped",
+    config_hash: str = "aaaa",
+    files: str = _FILES,
+    oneoff: str = "False",
+) -> dict:
+    return {
+        "Config": {
+            "Labels": {
+                _stack_state.SERVICE_LABEL: service,
+                _stack_state.PROJECT_LABEL: "dfe-docker",
+                _stack_state.WORKING_DIR_LABEL: "/opt/dfe",
+                _stack_state.CONFIG_FILES_LABEL: files,
+                _stack_state.CONFIG_HASH_LABEL: config_hash,
+                _stack_state.ONEOFF_LABEL: oneoff,
+            }
+        },
+        "State": {"Running": running, "ExitCode": exit_code},
+        "HostConfig": {"RestartPolicy": {"Name": restart}},
+    }
+
+
+def test_a_running_service_and_a_finished_one_shot_both_come_back() -> None:
+    found = _stack_state.containers(
+        [
+            _document("dfe-engine"),
+            _document("dlq-init", running=False, restart="no"),
+        ]
+    )
+
+    [restore] = _stack_state.restores(found)
+
+    assert restore.services == ("dfe-engine", "dlq-init")
+
+
+@pytest.mark.parametrize(
+    "document",
+    [
+        _document("dfe-loader", running=False),
+        _document("dlq-init", running=False, exit_code=1, restart="no"),
+        _document("dfe-engine", oneoff="True"),
+    ],
+    ids=["stopped-service", "failed-one-shot", "compose-run"],
+)
+def test_what_was_not_running_or_finished_cleanly_stays_down(document: dict) -> None:
+    assert _stack_state.restores(_stack_state.containers([document])) == []
+
+
+def test_the_restore_names_the_project_directory_files_and_profiles() -> None:
+    [restore] = _stack_state.restores(
+        _stack_state.containers([_document("dfe-engine")])
+    )
+
+    assert restore.command(["core", "clickhouse", "core"]) == [
+        "docker",
+        "compose",
+        "--project-name",
+        "dfe-docker",
+        "--project-directory",
+        "/opt/dfe",
+        "-f",
+        "/opt/dfe/docker-compose.yml",
+        "-f",
+        "/opt/dfe/docker-compose.tls.yml",
+        "--profile",
+        "clickhouse",
+        "--profile",
+        "core",
+        "up",
+        "-d",
+        "dfe-engine",
+    ]
+
+
+# The shape that matters: dfe-engine depends on both brokers, each optional and
+# gated by its own profile, so enabling every profile starts both.
+_MODEL = {
+    "services": {
+        "clickhouse": {"profiles": ["clickhouse"]},
+        "dfe-engine": {"profiles": ["core"]},
+        "kafka-apache": {"profiles": ["kafka-apache"]},
+        "kafka-redpanda": {"profiles": ["kafka-redpanda"]},
+        "dfe-instance": {},
+    }
+}
+
+
+def test_only_the_restored_services_profiles_are_enabled() -> None:
+    profiles = _stack_state.profiles_of(_MODEL, ["dfe-engine", "clickhouse"])
+
+    assert profiles == {"core", "clickhouse"}
+
+
+def test_a_service_with_no_profile_or_unknown_to_the_model_adds_none() -> None:
+    assert _stack_state.profiles_of(_MODEL, ["dfe-instance", "gone"]) == set()
+
+
+def test_the_config_command_reads_every_service_the_files_define() -> None:
+    [restore] = _stack_state.restores(
+        _stack_state.containers([_document("dfe-engine")])
+    )
+
+    assert restore.config()[-5:] == ["--profile", "*", "config", "--format", "json"]
+    assert "*" not in restore.command(["core"])
+
+
+def test_a_compose_file_that_is_gone_is_left_out_and_named() -> None:
+    found = _stack_state.containers([_document("clickhouse")])
+
+    [restore] = _stack_state.restores(
+        found, exists=lambda path: not (path.endswith("tls.yml"))
+    )
+
+    assert restore.config_files == ("/opt/dfe/docker-compose.yml",)
+    assert restore.missing == ("/opt/dfe/docker-compose.tls.yml",)
+    assert "/opt/dfe/docker-compose.tls.yml" not in restore.command()
+
+
+def test_services_started_from_different_files_get_one_up_each() -> None:
+    found = _stack_state.containers(
+        [
+            _document("dfe-engine"),
+            _document("dfe-ui", files="/opt/dfe/docker-compose.yml"),
+        ]
+    )
+
+    assert [restore.services for restore in _stack_state.restores(found)] == [
+        ("dfe-ui",),
+        ("dfe-engine",),
+    ]
+
+
+def test_a_project_put_back_as_found_shows_no_difference() -> None:
+    found = _stack_state.containers(
+        [_document("dfe-engine"), _document("dlq-init", running=False, restart="no")]
+    )
+
+    assert _stack_state.differences(found, found) == []
+
+
+def test_found_nothing_and_left_nothing_shows_no_difference() -> None:
+    assert _stack_state.differences([], []) == []
+
+
+@pytest.mark.parametrize(
+    ("after", "problem"),
+    [
+        ([], "'dfe-engine' has no container"),
+        ([_document("dfe-engine", running=False)], "'dfe-engine' is not running"),
+        (
+            [_document("dfe-engine", config_hash="bbbb")],
+            "'dfe-engine' is configured differently",
+        ),
+        (
+            [_document("dfe-engine"), _document("clickhouse")],
+            "'clickhouse' is running and was not",
+        ),
+    ],
+    ids=["gone", "stopped", "reconfigured", "extra"],
+)
+def test_each_way_a_project_can_differ_is_named(after: list, problem: str) -> None:
+    found = _stack_state.containers([_document("dfe-engine")])
+
+    problems = _stack_state.differences(found, _stack_state.containers(after))
+
+    assert len(problems) == 1
+    assert problems[0].startswith(problem)
+
+
+def test_a_stack_left_up_after_finding_none_is_a_difference() -> None:
+    problems = _stack_state.differences(
+        [], _stack_state.containers([_document("clickhouse")])
+    )
+
+    assert problems == ["'clickhouse' is running and was not"]