()
| 66 | type ExecutionCoreResult = Awaited<ReturnType<typeof executeWorkflowCore>> |
| 67 | |
| 68 | function incrementScheduleFailedCount(): SQL { |
| 69 | return sql`COALESCE(${workflowSchedule.failedCount}, 0) + 1` |
| 70 | } |
| 71 | |
| 72 | function scheduleStatusAfterFailedCountIncrement(): SQL { |
| 73 | return sql`CASE WHEN COALESCE(${workflowSchedule.failedCount}, 0) + 1 >= ${MAX_CONSECUTIVE_FAILURES} THEN 'disabled' ELSE 'active' END` |
no outgoing calls
no test coverage detected