Flows

Inflow

External service → your Postgres. Pull data from a SaaS API on a schedule, transform it, and load it into your Drizzle tables. Declare named variants (run modes) — each with its own optional cron schedule and onError/onComplete hooks — and branch on `ctx.variant` (e.g. `delta`, `full`, `healthcheck`). Tracked in the standard `khotan_runs` table — status, durations, batch counts, create/update/delete/fail tallies, plus a metadata JSON for component-specific stats. Toggle off with --no-runs.

eE → iL

stripe

transform

postgres

Install

$ npx khotan add inflow <source>

Variants

Named run modes, each independently schedulable with onError/onComplete hooks. The variant name is the mode — flow code branches on ctx.variant. Click a variant above to see the flow change, then select one when triggering.

await khotanData.flow('inflow').start({ variant: 'full' })

Documentation

See the full integration guide — schema, generated files, helper API, and configuration — in the Inflow docs.