Scale all Deployments for an instance to 0 replicas by label selector.

Score a candidate, lower is better. * Prefers candidates that share a common prefix with the unknown name.

Validate type compatibility on all edges. Compute the wire type for a port, accounting for lane mode transformations. Port types are post-operation. W

Parse a one-liner body's comma-separated `key: value` pairs into an array. * Respects double-quoted strings and nested `{ }` so commas inside them d

Split a one-liner config body on commas, respecting quotes and all * bracket depths `()` `[]` `{}`. Used by the one-liner node parser so * that in

Split port content on commas and newlines, respecting bracket depth.

Background task for trigger maintenance: - Heartbeat: Update last_heartbeat for owned triggers - Recovery: Claim triggers from crashed instances

Background task that aggregates usage_events into usage_daily once per hour.

Stop all running/pending triggers for a project (returns the trigger IDs that were stopped)

Download media from a source URL and store it as a temporary file via the API. Returns a media-compatible JSON object: `{ file_id, url, mimeType, fil

Strip inline comments: everything after # at bracket depth 0.

Get the submission sender. Used by the external handler that receives form submissions and forwards them to the waiting trigger.

Sweep TaskRegistry entries older than `max_age_days`. The Restate virtual object that backs TaskRegistry has no TTL, so abandoned tasks accumulate ind

Synthesize input ports for edges that target an undeclared port on a `canAddInputPorts` node. Rule: - Target has catalog input `x` → no synthesis (cat

Synthesize input ports for literal config values whose keys aren't declared anywhere by the catalog (not a catalog input port, not a catalog config fi

* Total messages across all chats.

One-call helper to get a tracked CompletionContext for an AI node. Handles API key resolution (BYOK vs platform), env-based API URL, and cost trackin

Build an inline-SVG background image for a gather/expand triangle port * with a visible 1px outline on all edges (including the slanted hypotenuses)

Try peeling List[] wrappers from source to find expand depth compatible with target.

Try peeling List[] wrappers from target to find gather depth compatible with source.

Try to materialize an inline anon into a standalone declaration at the * scope of its former host. Returns the new source, or null if the anon * c

Try to find how many List[] wrappers to peel from source to make it compatible with target. Returns Some(depth) if peeling `depth` List wrappers from

Try to find how many List[] wrappers to peel from target to make source compatible with the inner type. Returns Some(depth) if source is compatible wi

Top-level connection parser with inline RHS support. Accepts: - `target.port = source.port` (edge) - `target.port = InlineType { ... }.x` (in

Parse connections inside a group. Uses `self` instead of `in`/`out`. `child.input = self.port` (child receives from group input) `self.output = child.

Group-body connection parser with inline RHS support. Mirrors `try_parse_connection_with_inline` but uses `try_parse_group_connection` for the simple

Parse a single port declaration. Port declaration syntax: `name: Type` (required by default) or `name: Type?` (optional). No prefix characters. Lane m

Remove the trigger form from the TaskRegistry (cleanup on shutdown).

Update ports on a one-liner inline anon.

Update ports on a multi-line inline anon. The first line has the * `prefix Type [sig] {` shape; only that line needs to be rewritten because * the

Update heartbeat for all triggers owned by this instance

Update trigger config (used after trigger setup resolves upstream values)

Insert or update a trigger in the database. Credentials are encrypted before storage.

Validate that every edge references ports that exist on the source/target nodes. Returns errors for any edge that references a non-existent port.

Replace TypeVar references with their bound types. Recurses into List, Dict, Stack, Union. For every node, scan its input ports. For each port that is

Verify HMAC-SHA256 signature for webhook payloads

* Wait for initial history sync to complete (with timeout). * Returns immediately if history is already ready or if there are enough * messages

Wrap raw weft code in a 4-backtick fence so parseWeft can extract it.

Remove Null from a type. `String | Null` becomes `String`. A bare `Null` becomes `Null` (cannot strip further). Non-union types without Null are retur