createWakeJobRunner

function createWakeJobRunner(runtime, opts): (job) => Promise<void>;

Build the scheduler executor for wake jobs: runs the agent-initiated turn and hands the produced parts to deliver (e.g. the messaging outbound pipeline — which keeps the send window-safe). Compose with your own job kinds: run: (job) => isWakeJob(job) ? runWake(job) : runMine(job).

Parameters

Parameter	Type
runtime	WakeRunnable
opts	{ deliver: (delivery) => Promise<void>; onError?: (error, job) => void; }
opts.deliver	(delivery) => Promise<void>
opts.onError?	(error, job) => void

Returns

(job) => Promise<void>