Expand a one-liner group to multi-line format.

* Pick the sizing attributes (height, minHeight, maxHeight, width, chrome) * out of an attrs map. These apply to fields and outputs.

Find a node by its potentially scoped ID (e.g. Group.Group_2.debug_1).

Human form field specs shared by HumanQuery and HumanTrigger. Must stay in sync with HUMAN_FORM_FIELD_SPECS in frontend.ts.

Get a ready-to-use InfraClient for an infrastructure sidecar. `endpoint_url` is the sidecar's action endpoint URL, received through edges from the in

Compute the infrastructure instance ID for a given project and node. K8s label values are capped at 63 bytes, so we truncate the UUIDs. Format: wf-{12

True if `s` has matched `{`/`}` at depth 0, respecting quoted strings and triple-backtick code blocks. Used to know when a multi-line `{ ... }` one-li

Check if a line looks like it could be JSON content (not Weft syntax).

* Parse a sequence of blocks until we hit a line that's just `}` (end of our * enclosing block) or EOF. Returns the parsed blocks and advances state.

Parse a `.portName` suffix. Returns the port name on success.

Parse a `.portName` suffix. Accepts strings like `.text`, ` .text`, ` .text `. Rejects anything with extra characters after the port name.

Register and start a trigger using the NodeTypeRegistry. The config must contain a `nodeType` field specifying which node to use. The service looks u

Remove all connection lines that reference a given identifier (as source or target).

Unescape backslash sequences inside a quoted string, mirroring the * backend's weft_compiler::unescape helper: \n \t \r \" \\ are decoded, * unkno

Build the source-line array for `<indent><prefix><formattedValue>`. The * formatted value may be multi-line (heredoc or pretty-printed JSON/list).

Build the port signature string: `(port1: T, port2: T?) -> (out1: T)`

Build the scope chain for a group ID. "outer.inner" → ["outer", "outer.inner"] "mygroup" → ["mygroup"]

Shared prelude: turns inputs into Python variables and wraps the user code in a function so `return` works. `from X import *` lines are hoisted to mod

Remove a pending channel without resolving (e.g., on cancellation).

Check if the project has settled. Complete when: no Pending pulses AND no Running/WaitingForInput NodeExecutions. Returns Some(any_failed) if complete

Claim pending triggers for this instance (atomic operation) Returns triggers that were successfully claimed

Coerce config values to match the types expected by the node template. * Uses field definitions (type: 'number', 'textarea', etc.) and output port

Read a config value as u64 with coercion and fallback default.

Decrypt credentials from base64-encoded ciphertext. Returns the decrypted JSON value.

Dispatch a single node execution. Does NOT hold the per-execution mutex. Instance lookup uses the shared cache on ExecutorState (DashMap, lock-free).

Low-level edge emitter: emit pulses on outgoing edges. No laneMode awareness: routes values from the output object to downstream targets as single pul

Emit a Single output port value on all downstream edges from this port. One pulse per edge at the current lane.

Locate the inline body `{ ... }` span inside a single line of source. * Handles three line shapes (all are one-liner anons): * * normal

Extract port names from text containing -> (name: Type, ...).

Extract old port names from the declaration line(s) signature. * Parses `(name1: T, name2: T?) -> (out1: T)` from the header.

Extract TypeVar bindings by structurally matching a pattern against a concrete type. * E.g. pattern List[T] + concrete List[Dict[String, Number]] →

Extract content of [...] after keyword, handling nested brackets.

Backward-BFS subgraph extraction. Starting from `seed_ids`, walks backwards along incoming edges to collect all upstream dependencies. Optionally val

Extract the trigger setup sub-graph for a specific trigger node. Walks backwards from the trigger node, collecting all upstream dependencies (Config

Extract TypeVar bindings by structurally matching a pattern (with TypeVars) against a concrete type. E.g. pattern List[T] + concrete List[Dict[String,

Find a ParsedNode by id, tolerating both scoped (`grp.host__data`) and * local (`host__data`) forms. Searches top-level nodes first, then inside *

True if the first `{` in `s` is followed by real config content on the same line (not just whitespace or a trailing `#` comment). Used to distinguish

Format a config value for Weft syntax.

Format a CatalogNode into the same text format the backend uses for the builder prompt

* Get the oldest raw WAMessage for a chat (needed as cursor for fetchMessageHistory).

* Get the set of config keys that are sensitive for a given node type. * A field is sensitive if its type is 'password' in the node template.

Get the encryption key from environment. Environment variable: CREDENTIAL_ENCRYPTION_KEY (base64-encoded 32-byte key) In cloud mode: PANICS if key i

Returns the binary name and port env var for a node type. All node types use the same unified runner.

Look up the margin multiplier for a user. Priority: subscription custom_margin > tier margin > 1.6 (free tier default). Panics on DB errors or misconf

Metadata tag for human-facing forms. Used by both HumanQuery and HumanTrigger.

Atomically increment the setup_run_counter. Returns the new counter value. Use set_setup_execution_id() afterwards to register the execution ID built

Provision K8s resources for an infrastructure node during setup. Handles: resolve projectId/namespace, create K8s client, ensure namespace, apply man

Query the sidecar's /outputs endpoint during normal project execution. Reads `_endpointUrl` from the node's input (injected by the executor), calls G