import type { Job } from "bullmq"; import type { WorkerConfig } from "./config"; /** * Core job processor — coordinator role. * * The coordinator: * 1. Fetches run config, marks run as "running" * 2. Joins as a participant, starts 1 container in distributed mode * 3. Waits for its own container to exit * 4. Reports leave, then polls until all helpers are done too * 5. Posts final run status (completed/failed) * * Helper workers join runs via the heartbeat-join loop in cli.ts. */ export declare function processRunJob(config: WorkerConfig, job: Job<{ runId: string; }>): Promise<{ runId: string; status: string; }>; //# sourceMappingURL=processor.d.ts.map