Function reapStuckProcessingRows

apps/sim/lib/core/outbox/service.ts:248–263

* Reaper: move `processing` rows whose worker died (stale `lockedAt`) * back to `pending` so another worker can pick them up. Without this, * a SIGKILL between claim and result-write would permanently strand * the row in `processing`.

()

 * the row in `processing`.
 */
async function reapStuckProcessingRows(): Promise<number> {
  const stuckBefore = new Date(Date.now() - STUCK_PROCESSING_THRESHOLD_MS)
  const result = await db
    .update(outboxEvent)
    .set({ status: 'pending', lockedAt: null })
    .where(and(eq(outboxEvent.status, 'processing'), lte(outboxEvent.lockedAt, stuckBefore)))
    .returning({ id: outboxEvent.id })

  if (result.length > 0) {
    logger.warn('Reaped stuck outbox processing rows', {
      count: result.length,
      thresholdMs: STUCK_PROCESSING_THRESHOLD_MS,
    })
  }
  return result.length
}

/**
 * Phase 1: claim a batch of due pending events.