API Reference

workQueueReadinessHandoffProjector()

Consume D433 shared readiness through workQueue-owned handoff material.

Ready facts only produce queue-domain candidates/status. They do not claim work, expire leases, cancel, complete, fail, or append workQueue records. Lease expiration candidates can be lowered separately into the existing mutation-bearing expire-leases command path.

Import

import { workQueueReadinessHandoffProjector } from "@graphrefly/ts/orchestration/work-queue";

Signature

function workQueueReadinessHandoffProjector(
	graph: Graph,
	opts: {
		readonly name?: string;
		readonly records: Node<WorkQueueRecord<T>>;
		readonly ready: Node<ScheduledReadinessReady>;
		readonly overdue?: Node<ScheduledReadinessOverdue>;
	},
): WorkQueueReadinessHandoffBundle

Parameters

Returns

A node bundle that emits the projected records.

Example

import { workQueueReadinessHandoffProjector } from "@graphrefly/ts/orchestration/work-queue";

Source

packages/ts/src/orchestration/work-queue-scheduled-readiness.ts