Skip to main content

Module suspend

Module suspend 

Source
Expand description

SQL statements for suspend + claim_resumed_execution ops (RFC-023 Phase 2b.2.1).

Mirrors ff-backend-postgres/src/suspend_ops.rs statement-by- statement with SQLite-dialect adjustments (jsonb โ†’ TEXT, $n โ†’ ?n, FOR UPDATE elided under single-writer BEGIN IMMEDIATE).

Constantsยง

INSERT_SUSPEND_DEDUP_SQL
SELECT_ATTEMPT_EPOCH_SQL
SELECT_ATTEMPT_LEASE_EPOCH_SQL
SELECT_EXEC_ATTEMPT_INDEX_SQL
SELECT_EXEC_STATE_FOR_RESUME_SQL
SELECT_SUSPEND_DEDUP_SQL
SELECT_SUSPENSION_CONDITION_AND_MAP_SQL
UPDATE_ATTEMPT_CLAIM_RESUMED_SQL
UPDATE_ATTEMPT_SUSPEND_SQL
UPDATE_EXEC_CORE_RESUMABLE_SQL
UPDATE_EXEC_CORE_RUNNING_SQL
UPDATE_EXEC_CORE_SUSPEND_SQL
UPDATE_SUSPENSION_MEMBER_MAP_SQL
UPSERT_SUSPENSION_CURRENT_SQL
Binds: 1=partition, 2=execution_id, 3=suspension_id, 4=suspended_at_ms, 5=timeout_at_ms, 6=reason_code, 7=condition_json, 8=timeout_behavior.