Remove connections referencing ports that no longer exist.

Check if this execution has been cancelled by polling the executor. Derives the executor status URL from the callbackUrl (format: `{base}/ProjectExec

List triggers for a specific project

Derive a deterministic unique local port from an instance_id. Range: 10000-59999 (50000 slots, collision-resistant for typical projects).

A dotted ref is 2+ identifier segments joined by `.`, no quotes, no whitespace, no digits-only segments (so `3.14` is NOT a dotted ref). Used in inlin

Retries an idempotent registry lookup with exponential backoff. Returns None only after all attempts fail (transient or "not found"). Distinguishing "

Map form responses to output port values.

Replace every occurrence of the `T_Auto` marker in `port_type` with a key-scoped TypeVar like `T__{key}`. Other TypeVars (explicit `T`, `T1`, etc.) ar

Summary status for a node derived from its executions. Returns a string like "completed" or "completed (15 completed, 15 failed)" for multi-execution

Parse `(inputs) -> (outputs)` or just `(inputs)` from a string starting with `(`. Returns (in_ports, out_ports, one_of_required, remaining_string).

POST a status update (cancelled/completed/failed) to the dashboard's `/api/executions/{id}` endpoint. The dashboard enforces JWT auth on every `/api/*

Rebuild the declaration line(s) with new port signature. * Preserves the node id, type, and any trailing { or body.

Recover triggers from crashed instances (stale heartbeats)

Redact sensitive fields from a JSON value for safe logging. This recursively walks the JSON structure and replaces values of keys that match sensitiv

Resolve a pending channel with the form response. Returns false if not found.

Replace T_Auto markers in a port type string with key-scoped TypeVar names. * Returns the original string if parsing fails or no markers are present

Resolve the port name by replacing `{key}` with the actual field key.

Helper to restart a list of triggers with retry and exponential backoff. Retries each trigger up to ~10 minutes to give dependent infra time to come u

Rewrite the type-signature fragment of an inline anon's first line. * Given a prefix like ` data: Template(old: String) ` or * `host.data = Templ

Set the setup_execution_id for a trigger (without incrementing the counter).

Set a transitional pending action for a trigger (activating/deactivating). Upserts so repeated calls are idempotent.

Splice replacement into source at a match, preserving newline boundaries. * The key insight: if the source has a newline right after the match, incl

Split string on delimiter, but only at top level (not inside [])

Split `s` on `delimiter`, but only at top level: ignore delimiters inside strings, parentheses, square brackets, and curly braces. Used by the one-lin

Substitute TypeVars in a type string using bindings map

Suggest the closest match from a list of candidate names. Returns a * "did you mean" phrase or empty string if no close match exists.

Trim trailing whitespace from each line (but not leading).

Collect a multi-line literal RHS for a connection line. Handles two * forms: * - triple-backtick: `target.port = ```\n...\n``` ` (multi-line str

Parse a literal RHS value (quoted string, number, bool, JSON array/object) * into a JavaScript value. Returns undefined if the input doesn't match a

Check if all sibling lanes have completed for this node. If yes, build gathered lists for each gather port, absorb siblings, and emit at parent lane.

Try to parse a declaration: `id = Type(...)` or `id = Type { ... }` or `id = Type` If Type is "Group", parse as a group (body contains children). Port

Parse a literal RHS value (quoted string, number, bool, JSON array/object) into a serde JSON value. Returns None if the input doesn't match any litera

Unify a list of types. If all identical, return that type. Otherwise, return a union.

* Bulk-ingest messages (e.g. from messaging-history.set).

Get all registered node types.

Apply all manifests from an InfrastructureSpec into the given namespace. Injects ownership labels into every resource. Returns the list of (apiVersion

Apply ResourceQuota, LimitRange, and NetworkPolicy to a namespace.

* Convert an AudioBuffer to a WAV Blob.

Call weft-api's atomic gate+ledger endpoint. Local-mode policy lives in weft-api (no-op there). Retries 4x with ~15s total cap on transport errors and

Backfill daily aggregation for all missing days between last_aggregated and today. Called on server startup to recover from downtime.

Backfill daily usage aggregation for any days missed during server downtime.

Build cancel callback payload from NodeExecution records.

Build the status callback payload from NodeExecution records.

Build CORS layer based on environment configuration. Environment variables: - `DEPLOYMENT_MODE`: "local" (default) or "cloud" - `ALLOWED_ORIGINS`: Co

Build the full Python script that gets sent to E2B's /execute endpoint. The function's return dict is rendered as the cell's last expression wrapped i

Build the Python script for local execution (no Jupyter, no IPython). Returns a script that prints exactly one line `WEFT_RESULT_JSON=<json>` to stdou

Reconstruct nested output structure from NodeExecution records using their lane stacks.

Build ordering map from NodeExecution records.

Build sidecar image name from sidecarName. Uses SIDECAR_IMAGE_REGISTRY env var if set (cloud), otherwise defaults to ghcr.io/weavemindai (local).

Check if a user has sufficient balance to start infrastructure. Requires $5 reserve per running infra instance (including the one about to start). Ret

Check once whether the infrastructure pod is ready. Returns Ok(true) if ready, Ok(false) if not yet, Err on API failure.

Claim orphaned triggers that were running on other instances This is called on startup to reclaim triggers from instances that shut down

Clear the setup_execution_id for a trigger (set to NULL).

Copy triggers from the builder project into the deployment project. Called from within the publish transaction. Writes to `triggers` in the same tran

Coerce config values to match declared field types. Called automatically by the runner before execute().

Try to coerce a JSON value to a bool. Returns None if already a bool.

Try to coerce a JSON value to a number. Returns None if already a number.