Initialize pulses for a new project execution: one Pending pulse per source node.

Insert a `key: formattedValue` field into `node`'s body, just before the * closing `}` (or `}.port` for inline anons). The caller guarantees `node`

True if `s` has a matched `{` / `}` pair at depth 0, respecting quoted * strings and triple-backtick code blocks. Mirrors the backend * is_brace_b

Check if a line is a connection involving self (self.port = x.port or x.port = self.port).

Type variable names users can write: T, T1, T2, ... T99. * * Also accepted (catalog-internal only, not user-facing): * - `T_Auto`: sentinel use

Check if a node is inside a mocked group by checking its scope chain. Returns true if any entry in the node's scope matches a key in the mocks map.

Check if a JSON-like string has balanced brackets/braces.

True iff this node-runner is running in the local-dev deployment mode. Anything other than the literal value "cloud" is treated as local: this matches

Check if a key name suggests it contains sensitive data

Type variable names users can write: T, T1, T2, ..., T99. Also accepted (catalog-internal only, not user-facing): - `T_Auto`: sentinel emitted by cat

Keep the trigger alive (only for nodes with isTrigger: true). Called after execute() during trigger setup has completed. Starts the long-lived runtime

Kill any existing kubectl port-forward bound to this local port. Uses `lsof` to find the PID, then `kill -9` to terminate it.

Get the lane count for this execution (how many parallel lanes exist at this depth). Injected by the executor for nodes with Gather inputs. Defaults t

Lane mode overrides for specific ports. Ports not listed default to Single. Example: ForEach returns vec![("value", LaneMode::Expand)] for its output.

Two lanes are "compatible" (broadcast relationship) if one is a prefix of the other with matching SplitFrame.count at every shared level, or both are

Get the last aggregated date across all users. Returns None if no aggregation has ever been done.

List all triggers

List triggers stuck in setup_pending state (for recovery on restart)

List triggers for a specific user

Load triggers from database and restart them on startup

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

* Signal that the initial history sync has completed. * Called by bridge after the first `messaging-history.set` fires.

Recursively replace every `T_Auto` marker in a parsed WeftType with a * TypeVar scoped to the field key.

Merge trigger payload into input if applicable.

Narrow group-boundary passthrough output ports from their incoming-edge source types. A group `__in` / `__out` passthrough has identical input and out

Generate a unique callback ID for a form input request.

Compute port Y position for regular/collapsed nodes

Build a notify action payload. The executor intercepts this from the output and registers a pending task for the browser extension. Returns a JSON val

Parse the body of an inline expression: a `{` block starting at `startIdx`. * Mirrors parseNodeBlockBody but: * - When a `key: value` line has an

Port signature parser for an inline expression's header. * Given `after_type` (text after the node type, e.g. `(x: String) -> (y: String) {`), * r

* Parse a multi-line node config block starting AFTER the opening `{`. * Handles ```...``` multi-line values, label, JSON, string escapes. * Returns

Parse a one-liner-style body that spans multiple lines because a value * (typically a triple-backtick block or multi-line JSON) extends across * l

* Parse an options attribute: comma-separated values, or a JSON array. * `parseAttributes` has already unquoted the value, so here we just split.

* Unified scope parser. Handles both root scope (top-level weft) and group scopes. * The only differences controlled by `isRoot`: * - Root: no `}`

Deserialize the entire config into a typed struct.

Parse a multi-line config block (inside `{ ... }`). Returns (config, label, extra_in_ports, extra_out_ports, one_of_required, next_line_index). Share

Variant of parse_config_block that also returns the 0-based index of the line containing the closing `}` for the block. Callers that need to disambigu

* Permissive reflow pass. Runs BEFORE multi-line value preprocessing and * BEFORE the main parser. It turns LLM-friendly loose syntax into the * can

Build a `!pip install` line for any deps the user listed. Empty if none. We don't whitelist or validate package names here: E2B is the trust boundary,

POST /api/v1/publish/execute Internal service route. Called by cloud-api's public `/p/<u>/<slug>/run` after it rate-limited and credit-gated the requ

* Upload file bytes to a presigned URL using XHR (supports progress).

Re-dispatch trigger setup sub-executions for triggers stuck in setup_pending state. Called on startup to recover from crashes during trigger setup.

Register a new channel and return the receiver.

Register a form in the TaskRegistry as a persistent trigger form.

Render every populated MIME channel of a non-main display_data event into human-readable lines suitable for the stdout port. Binary channels are summa

Request form input mid-execution. Sends a form to a consumer (identified by metadata), blocks until the form is submitted, returns the response. Can

Send a WaitingForInput callback to the executor and await the form response. This is the core implementation called by `ExecutionContext::request_for

Rescope all internal IDs in a group from local_id prefix to scoped_id prefix.

* Recursively resolve the actual node type behind a source, tracing through * Group pass-through nodes.

Resolve the trusted userId for a start request. Cloud requires a valid `x-internal-api-key`. With the key present, prefer `x-user-id` (cloud-api inje

Execute the wrapped script via the host's `python3` interpreter. Used only when DEPLOYMENT_MODE != cloud. No sandboxing, no isolation: this is intende

Scale a Deployment to 0 replicas (stop without destroying data).