@flowforgejs/worker

Production-grade worker process for executing FlowForge workflows. Built on BullMQ for job queuing, Hono for the HTTP API, Drizzle/Postgres for persistence, and OpenTelemetry for observability. Supports cron-based scheduling out of the box.

Features: job queuing (BullMQ), HTTP API (Hono), persistence (Drizzle/Postgres), tracing (OpenTelemetry), cron scheduling

Install

npm install @flowforgejs/worker

Quick Example

import { createWorker } from '@flowforgejs/worker';

const worker = await createWorker({
  redis: { host: 'localhost', port: 6379 },
  database: process.env.DATABASE_URL,
  workflows: './src/workflows',
  telemetry: { enabled: true },
  cron: [{ pattern: '0 9 * * *', workflow: 'daily-report' }],
});

await worker.start();
// Worker listening on http://localhost:3000