APAS® FlowsGenerally Available

The operational layer of APAS® Cloud.

Triggers in. Outcomes out. A drag-and-drop canvas wired to every APAS® module, every native CRM, your BigQuery warehouse, and seven ad-platform Conversions APIs.

62 production nodes. At-least-once execution on a 40-replica worker fleet. Unlimited flows, unlimited runs. Build visually, run on the same HIPAA-compliant infrastructure that powers the rest of your stack.

Form Submission — Score LeadsLive · v3
APAS® CLOUDLookup Consentapas.lookupConsentLOGICConsented?logic.ifElsetruefalseLOGICSplit Eventslogic.ifElsetruefalseAPAS® CLOUDLookup Contactapas.lookupCrmContactLOGICRoute by Platformlogic.switchgooglemetatiktokmicrosoftlinkedinxdefaultAD PLATFORMSSend to Google Adsads.sendGoogleAdsAD PLATFORMSSend to Bing Adsads.sendBingAdsAPAS® CLOUDMark Processedapas.conversionTrackerAPAS® CLOUDMark No Consentapas.conversionTrackerAPAS® CLOUDScore Leadapas.scoreLeadLOGICIf Score ≥ 70logic.ifElsetruefalseAPAS® CLOUDMark Unattributedapas.conversionTracker
10 nodes · 62 available · 0 lines of codeSaved 2:24 PM
What it does

The canvas where the data you capture actually gets used.

APAS® Flows is the operational layer of APAS® Cloud. Every APAS® module already writes normalized, fully-attributed events into the platform — form submissions, scheduler bookings, phone calls, quiz completions, click-fraud detections, scheduled cron ticks, and inbound webhooks or Pub/Sub messages from any external system. APAS® Flows lets you react to any of them with a process you compose visually. Drag nodes onto the canvas in any order. Configure them. Click Publish. Runs on a hardened NestJS + BullMQ execution engine with at-least-once delivery, per-client concurrency, leader-locked schedulers, and node-by-node observability. 62 production nodes ship today, covering triggers, logic, code, data movement, your own database, BigQuery, CRMs, comms, and seven ad networks.

Capability pillars

Twelve reasons your stack collapses into one canvas.

Every capability ships in the same hardened execution engine. No tier-locked features. No 'enterprise add-on' walls.

Visual canvas, infinite shape

Drag-and-drop builder on @xyflow/react. Linear chains, branching trees, parallel fan-outs. Undo/redo, copy/paste, sticky notes, ⌘K palette, draft/publish versioning — all standard.

8 trigger types, including external

Form, call, scheduler, quiz, webhook, Pub/Sub, cron, manual. Per-node scope filters route the right trigger to the right flow without fan-out logic.

Real code when you need it

Dedicated TypeScript / JavaScript node with full async support and timeouts. SQL Query against Postgres or BigQuery. Run any custom logic without leaving the canvas.

APAS®-native enrichment

Look up contacts, pull attribution from BigQuery network_requests, fetch bot scores, score leads, push to PostHog, fire conversions. Operations no other platform has the data plumbing to do.

Multi-CRM, multi-ad-platform, native

Native adapters for GoHighLevel, Salesforce, ActiveCampaign, Keap. Native Conversions APIs for Google, Bing, Meta, TikTok, LinkedIn, Reddit, X.

Your own database, in the flow

Spin up tables in the built-in Database tab and read / write them with find / insert / update / upsert / delete. State management without standing up a datastore.

At-least-once execution

Trigger events written to a transactional outbox in the same Prisma transaction, keyed by SHA-256 idempotency. Stuck-row sweeper claims orphans. 40-worker fleet, BullMQ work-stealing via Redis.

Test Run dry mode

Fire a real trigger payload through a draft flow. Every node executes against live data — side-effect nodes (CRM writes, ad pushes, comms, IP blocks) automatically shadowed.

Node-by-node run logs

Every run records input JSON, output JSON, duration, and status for every node. One-click retry from any failed step. Copy a run back to the editor to debug visually.

Templating everywhere

{{ trigger.fieldName }}, {{ steps.<node>.<path> }}, {{ $vars.SECRET }} resolve at runtime. Hidden secrets stay in vars, never in the flow definition.

Encrypted credentials, HIPAA-ready

AES-256-GCM with rotatable key versions (FLOWS_ENCRYPTION_KEY_V{n}). One-click HIPAA preset enables 30-day payload retention with automatic PHI redaction.

Unlimited flows, unlimited runs

No operation cap. No "Enterprise tier to unlock parallel execution" wall. The worker pool scales horizontally with your tenant.

Complete node catalog

62 production nodes. Composable in any order.

Triggers, logic, code, your warehouse, your CRM, every ad platform — already integrated and audited. Browse by category, filter by name.

All categories
Triggers8 nodes
Triggers
Form Submitted
Pure / read
trigger.formSubmitted

Fires when a visitor submits any APAS® Form. Carries the full normalized payload (apasid, apasclid, all fields). Scopable to specific forms.

Template{{ steps.formSubmitted.output }}
ExecutionEntry point · idempotent
Test RunRuns as normal against live data — pure read.
ObservabilityInput JSON · Output JSON · Duration · Status — captured for every run.
Production node · GA
1 / 8 in Triggers
Example flows

A few patterns to get the wheels turning.

These are just examples — a handful of flows real APAS® Cloud tenants run in production today. With 62 nodes on the canvas, anything you can describe as a sequence of when this, then that can be built here. Drop these in as-is, fork them, or compose something nobody has thought of yet.

Example 01
Booking → CRM + Conversion

One flow, full attribution, every connected ad platform notified.

1
Triggers
Scheduler Submitted
2
APAS Cloud
Fetch Attribution
3
CRM
Upsert (Salesforce)
4
CRM
Tag "Booked"
5
APAS Cloud
Send Conversion · Green
Example 02
High-intent inbound call

200ms end-to-end: the sales rep gets pinged before the caller hangs up.

1
Triggers
Phone Call Completed
2
Logic
If duration > 90s
3
Comms
Send SMS
4
CRM
Upsert (GHL)
5
Ad platforms
Send to Google Ads · Yellow
Example 03
Quiz scoring + routing

High-band leads get a Gmail invite & calendar hold; low-band leads enter a drip — every score logged to BigQuery.

1
Triggers
Quiz Submitted
2
APAS Cloud
Score Lead
3
Logic
Switch on score
4
Comms
Send Gmail + Calendar
5
BigQuery
Insert score history
Example 04
Hourly Pipeline Activation

Drains the offline-conversion queue every hour, fanning reds, oranges, yellows, whites & greens to all ad platforms.

1
Triggers
Cron 0 * * * *
2
APAS Cloud
Claim Conversions (500)
3
APAS Cloud
Send Conversion · upstream
4
APAS Cloud
Conversion Tracker
Example 05
Fraud-detection response

Bot scores cross threshold → ad exclusion list updated + media buyer pinged + audit row written.

1
Triggers
click_fraud webhook
2
APAS Cloud
Fetch Bot Score
3
Logic
If score > 90
4
Data movement
HTTP → Google exclusion
5
Comms
Send Slack alert
6
BigQuery
Insert audit row
Example 06
Inbound webhook + sync response

A thin REST API on top of your warehouse — query BigQuery, shape the response, return JSON.

1
Triggers
Webhook · Wait Mode
2
Data movement
SQL → BigQuery
3
Logic
Set Data (response)
4
Data movement
Respond 200 + JSON
Example 07
External Pub/Sub event

Any external system can drive a flow — decoded envelopes, upsert + analytics in one shot.

1
Triggers
Pub/Sub Received
2
Logic
Preprocessor
3
CRM
Upsert Contact
4
APAS Cloud
Send to PostHog
Your flow
Whatever your business actually needs.

If you can sketch it on a napkin as a sequence of triggers and actions, it can run on Flows. Bring us your weirdest “we wish our stack could do this” — we'll build it on a call.

1
Any trigger
When something happens
2
Any logic
Decide, enrich, transform
3
Any outcome
Do the thing
Not on the list?Tell us the outcome you want. If a CRM, an ad network, or a warehouse has an API, Flows can talk to it.
Bring us a flow →
Native CRM adapters

Four CRMs, first-party. The rest, one HTTP call away.

Built-in upsert / tag / note / task / enroll for the CRMs most agencies and healthcare clinics run on. Anything else is reachable via the HTTP Request node.

GoHighLevel
Auth
Private Integration Token · per-location
Operations
Upsert · Tag · Note · Enroll
Salesforce
Auth
OAuth2 · SOQL upsert
Operations
Upsert · Tag · Task · Enroll
ActiveCampaign
Auth
API key (apiUrl + apiKey)
Operations
contact/sync · Tags · Automations
Keap
Auth
OAuth2 · Basic-auth refresh
Operations
Duplicate-by-email · Campaigns
RoadmapHubSpot · Pipedrive · Zoho. For anything else — the HTTP Request node hits any REST API on the planet.
Trust & compliance

HIPAA-ready. Audit-ready. Worker-fleet-safe.

The same hardening that powers the rest of APAS® Cloud — applied to every flow run.

  • AES-256-GCM credential encryption with rotatable key versions. Tokens never leak into logs or run payloads.
  • Transactional-outbox at-least-once delivery with SHA-256 idempotency keys — no lost events, no duplicate fires.
  • Per-tenant payload retention controls with a one-click HIPAA 30-day-redacted preset.
  • Every flow run auditable to the millisecond: who triggered it, which version executed, what each node received and returned.
  • Test Run dry mode shadows every side-effect node — CRM writes, ad-platform pushes, comms, IP blocks, conversion sends — iterate without consequences.
  • SSRF guards on every outbound HTTP node prevent internal-network exfiltration.
  • All execution runs on the same HIPAA-compliant infrastructure as the rest of APAS® Cloud, under the same BAA chain.
  • Leader-locked schedulers + worker-pool leader locks prevent double-fires across the 40-replica worker fleet.
Generally Available

APAS® Flows is GA to every APAS® Cloud client. 62 production nodes. 4 native CRM adapters. 7 ad-platform Conversions APIs. Unlimited flows, unlimited runs.

FAQ

Frequently asked

For most teams: a marketing-automation tool, a CDP, a reverse-ETL tool, and the custom engineering time spent stitching them together. APAS® Flows collapses all of that onto one canvas already wired to every APAS® module, every native CRM adapter, every ad-platform API, and your BigQuery warehouse.

Build it once. Run it forever.

Apply to APAS® Cloud and get APAS® Flows included on day one — every node, every adapter, no run caps.