Back to Activepieces

Benchmark

docs/install/architecture/benchmark.mdx

0.87.019.1 KB
Original Source

This benchmark answers one question for the recommended production shape: at the 1:10 app-to-worker ratio, how does throughput scale as you grow the fleet from 40 to 160 workers? It runs the worker-is-the-sandbox model on a real GKE cluster, against a same-region object store with signed URLs and official piece tarballs served from the CDN.

Short answer: throughput keeps climbing to 777 req/s at 160 workers, but not proportionally — the per-worker rate peaks at 80 workers and falls about 20% by 160. The workers are not what limits it: they stay under a fifth of their CPU cap throughout, while database CPU grows in step with throughput.

The shape under test: app tier, Redis job queue, Postgres, S3, and a one-flow-per-worker execution tier.

What's measured

A 4-node synchronous webhook flow that holds the HTTP connection open until the flow returns:

<Steps> <Step title="Webhook trigger"> Catches the request on a `/sync` URL and holds the connection until the flow finishes. </Step> <Step title="Math Helper"> Adds `2 + 3`. </Step> <Step title="Code step"> Runs `return inputs.sum + 1` inside an `isolated-vm` context. </Step> <Step title="Webhook response"> Returns the result, closing the held connection. </Step> </Steps>

The compute is sub-millisecond by design — everything measured below is orchestration (queueing, callbacks, sandbox boot), which is what actually shapes production latency.

Each fleet size is held at the recommended 1:10 ratio (1 app per 10 workers) and run warm (AP_REUSE_SANDBOX=true) — the engine process is reused between jobs.

Results

<CardGroup cols={2}> <Card title="777 req/s" icon="gauge-high"> Peak warm throughput — 16 apps, 160 workers. </Card> <Card title="6.1 req/s" icon="arrow-trend-up"> Best per-worker rate, at 80 workers. It falls to 4.9 by 160 — adding workers keeps adding throughput, but less of it each time. </Card> </CardGroup>

Each worker is one sandbox at concurrency 1, hard-capped at 0.5 vCPU / 1 GB. Apps are 1 vCPU / 1 GB. Load concurrency is matched to the worker count so requests don't queue behind the concurrency-1 workers. All 160,000 requests across the four tiers returned 200.

Apps · WorkersRatioWarm req/sWarm req/s per worker
4 app · 40 workers1:10213.05.3
8 app · 80 workers1:10484.46.1
12 app · 120 workers1:10641.05.3
16 app · 160 workers1:10777.04.9

What each tier ran — and what it was actually doing

Only the app and worker counts scale (1:10). Postgres and Redis are a single fixed-size pod each — the same for every row below. CPU is sampled every 3 s throughout the measured pass; the singletons' figures are the whole pod, app/worker are per pod.

Read the two right-hand columns differently from the two on the left. Only the worker has a CPU limit (requests == limits == 500m, a hard cap). Postgres, Redis and the app declare CPU requests — a scheduling reservation they may burst above on a node with spare cores — so their numbers show what each tier consumed, not how close it came to a ceiling.

Apps · WorkersWarm req/sPostgres used (req 3000m)Redis used (req 2000m)App used (req 1000m, per pod)Worker used / cap (per pod)
4 · 40213529m123m537m81m / 500m
8 · 804841096m256m523m82m / 500m
12 · 1206411689m337m599m92m / 500m
16 · 1607772738m781m611m91m / 500m

Postgres is by far the fastest-growing tier. It climbs 529m → 2738m as the fleet quadruples — 5.2× the CPU for 4× the workers — and ends up the single largest CPU consumer in the deployment, above the entire 160-worker fleet combined (~14.6 cores across workers vs 2.7 in one database process, but spread over 160 pods versus one). Its cost per unit of work is near-constant (~2.5 millicores per req/s at every tier), so it grows with throughput, not with fleet size, and no configuration makes it stop growing. Redis behaves the same way (123m → 781m).

By contrast the workers — the only hard-capped tier — sit at ≤0.1 of their 0.5-core cap at every fleet size, and apps hold steady at ~0.52–0.61 of a core per pod because the 1:10 ratio adds app capacity in step with the load.

<Warning> **What this run does and does not establish.** It shows *consumption*: database CPU scales linearly with throughput while the worker fleet stays far below its cap, so the workers are demonstrably **not** what limits the curve. It does **not** prove the database is the bottleneck — Postgres here has no CPU limit and the nodes had spare cores, so 2738m is what it used, not a ceiling it hit. Pinning down the actual constraint (database CPU, lock contention, connection pool, or round-trip count per run) needs a follow-up with a hard-limited database and wait-event analysis. Treat "scale the database alongside the fleet" as the prudent reading of a linear growth trend, not as a measured saturation point. </Warning> <Note> The singletons here are deliberately generous (3 vCPU request, `max_connections=2000`, durability off, data dir on tmpfs). A **managed** Postgres at the 2 vCPU / 4 GB this documentation recommends, with fsync on and real disks, does less work per commit than this one and will feel the same load **sooner**. Size the database against your peak throughput, not against your worker count. </Note>

How throughput scales

Adding workers always adds throughput, but the return per worker falls after ~80. Total throughput goes 213 → 484 → 641 → 777 (3.6× for 4× the fleet). Per worker that is 5.3 → 6.1 → 5.3 → 4.9: the rate peaks at 80 workers and then gives back about 20%.

Two things are happening at once:

  • Below ~80 workers the fleet is still filling out. 40 workers cannot push enough concurrent work to use the tiers behind them, so the per-worker rate is not yet at its best. This is why the 40→80 step is super-linear (2.27× throughput for 2× the fleet).
  • Past ~80 workers, per-flow time stretches. The measured sandbox run phase goes 146 ms at 80 workers to 181 ms at 160, so each worker completes fewer flows per second even though it is nowhere near its CPU cap. Something shared is absorbing the extra concurrency, and database CPU is the tier visibly growing with it (see the caveat above — growth is measured, causation is not).

The concurrency-1 worker model sets the shape: each worker is busy for the whole per-flow time — engine run plus the end-of-run run-log persistence it finishes before taking the next job — so fleet throughput is workers ÷ per-flow-time. That is linear in the fleet only while per-flow time holds constant, and past ~80 workers it does not. (The synchronous response reaches the client sooner than that — it is sent at the response step, before the worker wraps up the log write — so client-perceived latency is lower than the worker-busy time that sets throughput.)

What this means for sizing: worker count is the right lever up to roughly this scale, but do not read the worker fleet as the only dial — the shared tiers behind it grow with throughput and need to grow with you.

<Note> **Why Production Setup recommends 1:10.** Apps at 1 vCPU are cheap relative to the worker fleet, and 1:10 is the warm-headroom margin that keeps the app tier from becoming the wall during bursts — it holds here, with apps steady at ~0.6 of a core per pod at every tier. See [Production Setup](/install/configure-operate/production-setup). </Note>

Latency anatomy

Where the worker's milliseconds go — warm at peak (16 app · 160 w), averaged over all 64,000 measured runs:

LayerWarm
Provision (flow bundle + piece + engine, all disk-cache hits)0.5 ms
Sandbox boot (engine process reused)~0 ms
Flow run (4 steps: engine→app callbacks + end-of-run log persist)181 ms
Worker-busy avg per job~181 ms

Warm provisioning and boot are effectively free — the piece cache is on local disk and the engine process is reused, so essentially the entire worker-busy time is the flow run itself. That figure grows with the fleet (167 ms at 40 workers, 146 ms at 80, 167 ms at 120, 181 ms at 160), which is the per-flow stretch behind the falling per-worker rate above.

This is the time the worker is occupied per job — and at concurrency 1 it is what sets throughput (workers ÷ worker-busy-time). The synchronous client sees less: the response is published at the flow's response step, before the worker finishes persisting the run log, so client-perceived latency runs below the worker-busy figure. At peak the in-cluster client measured p50 180 ms, p95 288 ms, p99 652 ms.

Test environment

  • Cluster: GKE n2-standard-16 × 10 nodes, europe-west1-b
  • Worker: 0.5 vCPU / 1 GB, concurrency 1, SANDBOX_CODE_ONLY (Node fork + isolated-vm). Idle RSS ~145 Mi
  • App: 1 vCPU / 1 GB
  • Object store: same-region GCS bucket (europe-west1) over the S3-interop endpoint, path-style SigV4 presigned URLs (AP_S3_USE_SIGNED_URLS=true)
  • Piece bundles: official tarballs served from the Activepieces CDN (AP_USE_CDN_FOR_BUNDLES=true)
  • Postgres + Redis: in-cluster singletons, deliberately generous — Postgres requesting 3 vCPU / 3 GB with max_connections=2000 (the default 100 would starve the app pools past ~10 apps), durability off, and its data dir on tmpfs; Redis requesting 2 vCPU / 2 GB with io-threads. Neither has a CPU limit, so both may burst above their request; Postgres consumed 2738m at the top tier
  • Load: hey run inside the cluster, against the app Service, concurrency matched to worker count (40/80/120/160) so requests don't queue behind the concurrency-1 workers — latency reflects real service time, not backlog. 400 requests per worker per tier (16k/32k/48k/64k), preceded by an unmeasured warmup pass
<Warning> **Generate the load in-cluster.** Driving 120+ concurrent sync webhooks from a workstation over the public LoadBalancer exhausts the client's ephemeral port range (macOS offers ~16k; `hey` then dies with `can't assign requested address`) and the run collapses in a way that looks exactly like a server-side ceiling at the 120-worker tier. Externally-driven and in-cluster runs agree at 40 workers and diverge sharply above 80 — if you reproduce this, put the generator in the cluster or you will measure your laptop. </Warning>

How to reproduce

bash
benchmark/run-gke.sh [total_requests] [concurrency]

The script mints a worker token, deploys benchmark/k8s-sandbox.yaml to the cluster, runs the load test from a pod inside the cluster, and reports warm throughput and the per-run breakdown from worker-pod logs. Set APP_REPLICAS and WORKER_REPLICAS (keeping the 1:10 ratio) to reproduce any row in the results table.

<Tip> This benchmark runs in `SANDBOX_CODE_ONLY` mode. It does **not** represent the performance of Activepieces Cloud, which uses a different sandboxing mechanism for multi-tenancy. See [Sandboxing](/install/architecture/sandboxing). </Tip>

Benchmark your own installation

Load-test and diagnose your own deployment — no cluster scripts required — with the CLI. It publishes a synchronous flow (webhook trigger → data mapper → return response), fires load at its sync webhook endpoint with autocannon, and returns one self-contained diagnostic bundle you can hand to support.

bash
AP_API_KEY=<key> npx @activepieces/cli@latest benchmark --url https://your-instance.example.com

The CLI provisions a throwaway project for the run (with a high concurrency cap so a project rate limiter can't queue-throttle the numbers) and deletes it when finished — nothing is left behind, and it never touches your real projects. The API key must be a platform-admin key.

Why the numbers are trustworthy. The CLI runs from a different region than your servers, so its client-side latency is polluted by network distance. The numbers that matter are measured server-side instead: the QUEUE/PROVISION/BOOT/RUN split is timed inside the worker, and DB/Redis/S3 round-trips are measured in-region by an admin diagnostics endpoint. Client numbers are shown but marked observational.

Concurrency defaults to your execution slotsAP_WORKER_CONCURRENCY across connected workers) so requests don't queue and you read real service time, not backlog. Comparing two deployments? Match concurrency to each one's own slots — never a fixed number, which makes the smaller one queue.

OptionDefaultDescription
--urlhttp://localhost:3000Base URL of your instance
--api-keyAP_API_KEY env varPlatform-admin API key (Bearer) — required
--concurrencyauto = execution slotsConcurrent connections
--requests40 × concurrencyTotal requests to fire
--body{"test":true}JSON body sent to the webhook
--jsonEmit the full machine-readable bundle (share with support)

Reference numbers

A real run against a small deployment of the recommended shape — 4 workers @ 0.5 vCPU / 1 GB, concurrency 1, SANDBOX_CODE_ONLY, AP_REUSE_SANDBOX=true, same-region GCS with signed URLs, warm, load = concurrency 4 (= slots) × 200 requests. This is a separate, deliberately tiny deployment used to show what the CLI's output looks like; it is not a row in the results table above, and its cross-region client latency is not comparable to those numbers.

Run the CLI against your own deployment and compare tier by tier. A number several times larger localizes the problem: RUN ≫ 200 ms means a heavier flow or a CPU-starved worker; storage ≫ 240 ms means a mis-regioned or throttled object store; a large QUEUE with climbing queue depth means you drove more concurrency than you have slots.

text
Version & health
  app version : 0.86.2 (latest available: 0.86.2) — all workers match app version
  health      : app-cpu=ok app-ram=ok disk=ok worker-cpu=ok worker-ram=ok db=ok

Infra round-trip (server-measured, in-region — authoritative, not reachable from the CLI)
  database : 21 ms
  redis    : 17 ms
  storage  : 237 ms   (S3/GCS write+read round-trip; same cost is inside every RUN as the end-of-run log backup)
  config   : execution=SANDBOX_CODE_ONLY storage=S3 signedUrls=true sandboxMemKB=1048576 s3=https://storage.googleapis.com/europe-west1
  workers  : 4 connected
    - ONLINE worker-z | 0.5 core | cpu 100.0% | ram 13.8%
    - ONLINE worker-N | 0.5 core | cpu  63.9% | ram 15.2%
    - ONLINE worker-u | 0.5 core | cpu 100.0% | ram 15.5%
    - ONLINE worker-e | 0.5 core | cpu 100.0% | ram 15.5%

Config flags (server-reported)
  EDITION "ce"   DEFAULT_CONCURRENT_JOBS_LIMIT 1000   PROJECT_RATE_LIMITER_ENABLED false
  FLOW_RUN_MEMORY_LIMIT_KB 1048576   WEBHOOK_TIMEOUT_SECONDS 30   FLOW_RUN_TIME_SECONDS 600  ...

Setup
  workers online : 4, execution slots : 4
  [PASS] sandbox mode / reuse sandbox / worker concurrency / worker CPU / worker RAM   (all match the recommended shape)

Network (CLI -> server, cross-region)
  RTT min / p50 : 43.0 / 46.9 ms over 20 probes

conc 4 (= slots)
  throughput   : 10.0 req/s   (200 reqs in 20.0s)
  run outcomes : 200 SUCCEEDED   (server-truth: 200 2xx, 0 non-2xx, 0 errors, 0 timeouts)
  queue depth  : max waiting 3, max active 4, avg waiting 1   (sampled server-side during load)
  worker-measured latency (authoritative — each phase timed inside the worker, 200 runs):
    QUEUE      p50 100 ms   — wait for a free execution slot  (±app↔worker clock skew; cross-check the queue-depth)
    PROVISION  p50   1 ms   — piece install / cache provision
    BOOT       p50   0 ms   — engine fork + Node boot + isolate + socket connect
    RUN        p50/p90 201 / 244 ms   — engine executes the flow, incl. end-of-run S3 log backup
    => queue-wait p50 102 ms vs service p50 201 ms  =>  verdict: service-bound
  observational (CLI-side, cross-region — NOT authoritative): client latency p50/p90/p99 256/311/5638 ms

Storage (log persistence)
  50/50 sampled runs have a persisted log — the worker->storage write path is healthy

Each section answers one question:

SectionWhat it measuresWhere it's measured
Version & healthApp release, whether every connected worker matches it (a version-skewed worker is silently withheld jobs), and app/worker/DB CPU-RAM-disk healthGET /v1/health/system
Infra round-tripAuthoritative in-region DB / Redis / S3 write+read latency, the effective execution/storage config, the app tier (every app replica's CPU / RAM / disk / event-loop — apps self-register into a diagnostics cache on their metrics tick), and the worker fleet with live per-worker CPU. The S3 round-trip is the same cost folded into every run's end-of-run log backup — a slow object store shows up here and in RUN. Self-hosted only.GET /v1/health/diagnostics
Config flagsThe limits and throttles that silently cap throughput — a PROJECT_RATE_LIMITER_ENABLED or a low DEFAULT_CONCURRENT_JOBS_LIMIT re-queues jobs (latency, not errors); the memory/timeout/log ceilings that turn into MEMORY_LIMIT_EXCEEDED / TIMEOUT / LOG_SIZE_EXCEEDED statusesGET /v1/flags
SetupExecution slots (Σ AP_WORKER_CONCURRENCY) and a PASS/WARN check of every worker's specs, sandbox mode, reuse, and concurrency against the recommended shapeGET /v1/worker-machines
NetworkCLI→server round-trip, so cross-region distance is quantified and subtracted rather than blamed on the servertimed GET /v1/flags
Load + latency splitThroughput, run-status outcomes (server truth, not just HTTP codes), live queue depth during load, and the per-run latency split into QUEUE / PROVISION / BOOT / RUN — measured inside the worker, so it's the same on any deployment regardless of where the CLI runs. The verdict says whether latency is queue-bound (too much concurrency for the slot count) or service-bound (real engine time)FlowRun.timeline + GET /v1/worker-machines/queue-metrics
StorageFraction of runs whose logs were persisted — proves the worker→storage write path works end to endFlowRun.logsFileId

Here the read is unambiguous: workers pegged at ~100% of their 0.5-core limit and RUN ≈ 200 ms dominate, while QUEUE (~100 ms at concurrency = slots) and the infra round-trips are small — the deployment is service-bound on worker CPU, so the lever is more/bigger workers, not a code change.

  • Exits non-zero if any request fails — usable as a CI gate.
  • The throwaway project (and its benchmark flow) is deleted automatically when the run finishes.
<Note> If your hardware or sandbox mode differs from the recommended shape, the absolute numbers shift — but the **shape** holds: match concurrency to your own slot count so nothing queues, then read whether you are queue-bound or service-bound and which tier dominates. </Note>