All use-cases

Commerce & Ops

Shopify to Notion pipeline sync

Resumable queue/worker sync pulls Shopify records, maps fields, lands them downstream idempotently.

Chunked, resumable, and safe to retry — duplicates are skipped, failures are queued.

The sync processes 100 records per chunk and persists a cursor so it can resume after any interruption. Three automatic gates guard the loop: re-enqueue if more pages remain, skip already-synced records, and retry with exponential backoff before routing exhausted jobs to a dead-letter queue.

Bell = in-app alert Amber diamond = automatic check
Connect source + destination ConnectorRegistry: Shopify + Notion enqueueSync creates sync_runs row, sends first job to queue handleSyncMessage 100 records/chunk, cursor persisted to sync_state More pages? no yes Re-enqueue next chunk (resumable) retry Already synced? no yes Skip duplicate idempotency cache hit Delivery fails? no yes Backoff + retry exhausted DLQ writer Sync run complete sync-finished alert
app/sync/shopify
Live demo

recording from the demo site — coming soon

Resumable, idempotent, and DLQ-safe. The worker processes 100 records per chunk and persists a cursor — three automatic gates handle pagination, duplicate detection, and retry with exponential backoff before routing exhausted jobs to the dead-letter queue. A sync-finished alert fires when the run completes.