primus.cli.procedure.scheduled_continuation module

Strict shared contract for native Tactus scheduled continuations.

The payload is intentionally small because it is copied into durable Procedure and Task metadata. It contains no provider error text or mutable execution state; the indexed Tactus checkpoint remains the authority.

primus.cli.procedure.scheduled_continuation.canonical_time_wait_request(value: Any) → dict[str, str] | None

Validate and normalize the exact public Procedure.defer payload.

primus.cli.procedure.scheduled_continuation.time_wait_is_due(request: Mapping[str, Any], *, now: datetime | None = None) → bool

Return whether a validated scheduled continuation is due, inclusively.