For the complete documentation index, see llms.txt. This page is also available as Markdown.

Module Reference

Every module an application flow can be built from.

Inputs

Module
Type
Tier
What it does

DatasetSource

reactive

Read from a saved dataset in your workspace.

ConnectorImport

durable

Run a connector import through a bound credential and materialise the rows as a dataset version.

OriginGrid

reactive

Emit origin timestamps for walk-forward or backtest sweeps.

ConfigInput

reactive

Provide a config JSON bag with defaults for downstream modules.

ScenarioInput

reactive

Lets viewers of the published app adjust simulation parameters within your bounds.

TableInput

reactive

Lets viewers of the published app enter or paste data rows the flow runs on.

Outputs

Module
Type
Tier
What it does

DatasetOutput

durable

Write the result back to a dataset.

ConnectorWrite

durable

Write the incoming rows to a table or object path through a bound connector.

APICall

durable

Send data to an external API endpoint.

SendNotification

durable

Post an alert to Slack or a webhook when an upstream branch fires.

APIResponseOut

reactive

Sends the final response payload back to the API caller.

EmitEvent

durable

Publish a named application event with a JSON payload for other applications to subscribe to.

Data Processing

Module
Type
Tier
What it does

DataOperations

reactive

Transform data with filters, joins, aggregations, and 27 other operations.

Conditional

reactive

Route data to different branches based on conditions.

Gate

reactive

Assert row counts, null rates, keys, ranges, freshness or a pinned schema before data flows on.

Buffer

durable

Accumulate arriving rows in a staging dataset and emit them as one batch when flushed or a bound is hit.

Intelligence

Module
Type
Tier
What it does

CallLLM

durable

Generate text, JSON, or tabular data using a large language model.

InterventionSim

reactive

Simulate the effect of interventions on a Digital Twin.

CounterfactualSim

reactive

Find what inputs would produce a desired outcome.

ForecastSim

reactive

Generate forward-looking predictions from a Digital Twin.

ForecastBacktest

durable

Score past forecasts against what actually happened — accuracy over time.

ScoreForecast

reactive

Score a forecast dataframe against actuals — horizons, MAPE, WMAPE, and more.

BacktestScores

durable

Pool matched forecast rows across origins into per-variable and per-lead-time accuracy.

AggregateForecast

reactive

Roll a finished panel forecast up into named environment groups defined by a dimension column or SQL rules.

StaticAccuracy

reactive

Score a static model on new labeled rows for selected target columns and metrics.

OptimisationSim

durable

Find optimal variable settings for a target outcome.

RCASim

durable

Identify root causes of anomalies or outcomes.

AnomalySim

durable

Detect anomalies and outliers using a Digital Twin.

TrainModel

durable

Train a new Digital Twin model from data.

UpdateModel

durable

Retrain or update an existing Digital Twin with new data.

ForEach

durable

Run an inline body subgraph once per row of an items dataframe.

While

durable

Repeat a body subgraph until a condition holds or the iteration cap is reached, carrying state in shift registers.

SubApp

durable

Use a published application as a module: its exposed terminals become this node's ports, pinned to one version.

Code

reactive

Run sandboxed Python to transform data or emit JSON.

PreScore

durable

Score a grid of scenarios in one durable twin run and fill the scenario store reactive simulations answer from.

Library

Module
Type
Tier
What it does

Box

durable

Drop a published box — a saved fragment of flow — in as one node.

Events

Module
Type
Tier
What it does

APIRequestIn

reactive

The HTTP request event: body, query, headers and the sync or async response mode.

OnSchedule

durable

Start a flow on a cron schedule, optionally spread over partition keys.

OnDataArrival

durable

Start a flow when a dataset is uploaded, synced, changed or its schema drifts.

OnTwinChange

durable

Start a flow when a digital twin is trained or updated.

OnInterval

reactive

Tick the reactive tier every N seconds so a live dashboard re-reads its connector without polling.

OnWebhook

durable

Start a flow when an external service POSTs to this application's webhook URL.

OnPanelEvent

reactive

Start a flow when a widget emits click, change, submit, rowSelect, pageOpen or pageClose.

OnAppEvent

durable

Start a flow when another application in this workspace emits a declared event.

Primitives

Module
Type
Tier
What it does

Select

reactive

Keep or drop the named columns.

Filter

reactive

Keep the rows a condition matches; values may read {{params.*}}.

Join

reactive

Join left and right on key columns.

Union

reactive

Stack the rows of a and b, by column name or position.

Aggregate

reactive

Group by columns and compute measures.

Compute

reactive

Add columns from expressions; values may read {{params.*}}.

Window

reactive

A window function over partitions in order: rank, lag, rolling sums.

Resample

reactive

Bucket a time column to a cadence and aggregate each bucket.

Pivot

reactive

Turn the values of one column into columns.

Unpivot

reactive

Turn columns into rows of variable and value.

Sort

reactive

Order rows by columns.

Limit

reactive

Keep the first n rows after an offset.

Distinct

reactive

Drop duplicate rows, over all or the named columns.

Rename

reactive

Rename columns.

Cast

reactive

Change column types.

Fill

reactive

Fill nulls with a value, a neighbour or the mean.

Sample

reactive

Keep n rows, chosen arbitrarily but the same ones each run.

Constant

reactive

Emit one typed value.

Expression

reactive

Compute one value from a, b and c with the scalar grammar.

Compare

reactive

Compare a with b and emit a boolean.

Pick

reactive

Read one value out of a JSON by path.

Merge

reactive

Merge two JSON objects, b over a.

ToTable

reactive

Turn a JSON of records or columns into a dataframe.

FromTable

reactive

Turn a dataframe into a JSON of records or columns.

Switch

reactive

Route by a value: one out-port per case, then otherwise.

Await

reactive

Continue when all or any of the inputs have arrived.

Delay

durable

Hold a value for a number of seconds on a Temporal timer.

Poll

durable

Check a GET endpoint until its response matches a condition or the time limit is reached.

ResolveTwin

reactive

Look up a digital twin's latest or pinned version as JSON.

ConnectorRead

reactive

Read a table or query through a bound connector without writing a dataset, cached for ttlS.

SeriesView

reactive

A forecast or scenario series seen through a view: time bucket, cumulative or per period, cohort and variable from a config's fields, plus a fixed roll-up and history.

Port kinds

An out-port may be wired to an in-port whose kind is listed here.

Kind
Connects to

dataframe

dataframe, signal

scalar

scalar, json, text, signal

json

json, scalar, signal

text

text, scalar, signal

document

document, binary, signal

image

image, binary, signal

binary

binary, document, image, signal

signal

signal

event

event, json

Last updated