Function checkFailureRate

apps/sim/lib/workspace-events/rules.ts:45–75

* Fires when the in-window failure rate meets the threshold with at least * SIM_MIN_EXECUTIONS_FOR_RATE_RULES executions. * * Intentionally diverges from the legacy notification rule, which required * the oldest in-window log to predate the window start — a condition that is * false for every i

(
  workflowId: string,
  ratePercent: number,
  windowHours: number
)

 * false for every in-window log, making the legacy rule dead code.
 */
async function checkFailureRate(
  workflowId: string,
  ratePercent: number,
  windowHours: number
): Promise<boolean> {
  const windowStart = new Date(Date.now() - windowHours * 60 * 60 * 1000)

  // Single DB-side aggregate: the window is user-configured and this runs on
  // the execution-completion path, so never materialize the in-window rows.
  const result = await db
    .select({
      total: count(),
      errors: count(sql`case when ${workflowExecutionLogs.level} = 'error' then 1 end`),
    })
    .from(workflowExecutionLogs)
    .where(
      and(
        eq(workflowExecutionLogs.workflowId, workflowId),
        gte(workflowExecutionLogs.startedAt, windowStart),
        excludeSimExecutionsCondition()
      )
    )

  const total = result[0]?.total ?? 0
  if (total < SIM_MIN_EXECUTIONS_FOR_RATE_RULES) return false

  const errorCount = result[0]?.errors ?? 0
  const failureRate = (errorCount / total) * 100

  return failureRate >= ratePercent
}

async function checkLatencySpike(
  workflowId: string,