ZFlowIn Development

ZFlow

In Development

Durable execution, event streaming, and code runtime.

DRI: Wiley Jones
Overview

ZFlow is the system of action. Every side-effect in a DOSS application — a write to an external API, a scheduled task, a user-triggered automation — runs as a durable workflow with checkpointed state. Built on Restate under the hood, it gives every ZSL program the same retry, replay, and observability story out of the box.

Execution model

What durable execution buys you

Crash-safe side effects

A workflow can outlive the process running it. State is checkpointed after every step; on restart the runtime picks up exactly where it left off.

At-least-once with idempotency hints

Calls to external APIs are journaled. The runtime surfaces idempotency keys so retries don't double-charge a vendor or double-send an email.

Replayable history

Every execution is a record of its own inputs, outputs, and decisions. Step through a week-old run to see exactly what the workflow saw.

No workflow-as-YAML

Workflows are TypeScript code authored in ZSL. The durability is a runtime property, not a config surface.

How work enters the system

Trigger surface

TriggerSourceDeliveryTypical use
Data changeZebraDB CDC → KafkaAt-least-once, keyed by rowSync, recalc, index update
ScheduleCron expressionAt-least-once, wall-clock firesNightly rollups, reminders
WebhookTenant-scoped URLExactly-once via dedup keyVendor callbacks, EDI drops
User actionApp UI or agent callExactly-once via request IDApprovals, kick-off jobs
Flow outputAnother ZFlow runTyped channelFan-out, sagas

Stack

RestateDurable execution runtime.
KafkaEvent bus for CDC and inter-workflow channels.
ClickHouseHot storage for execution traces.
OpenTelemetryTrace export to any OTLP-compatible backend.
PrometheusWorkflow success/failure counters, latency histograms.
ZSL compilerLowers application logic into ZFlow workflow programs.

In the stack