consolidate consts

Author: waleedlatif1

apps/sim/app/workspace/[workspaceId]/w/[workflowId]/components/panel/components/editor/components/sub-block/components/schedule-info/schedule-info.tsx

@@ -3,6 +3,7 @@ import { Badge } from '@/components/emcn'
 import { parseCronToHumanReadable } from '@/lib/workflows/schedules/utils'
 import { useRedeployWorkflowSchedule, useScheduleQuery } from '@/hooks/queries/schedules'
 import { useSubBlockStore } from '@/stores/workflows/subblock/store'
+import { MAX_CONSECUTIVE_FAILURES } from '@/triggers/constants'
 
 interface ScheduleInfoProps {
   blockId: string
@@ -46,7 +47,7 @@ export function ScheduleInfo({ blockId, isPreview = false }: ScheduleInfoProps)
       {(failedCount > 0 || isDisabled) && (
         <div className='space-y-1'>
           <div className='flex flex-wrap items-center gap-2'>
-            {failedCount >= 100 && isDisabled ? (
+            {failedCount >= MAX_CONSECUTIVE_FAILURES && isDisabled ? (
               <Badge
                 variant='outline'
                 className='cursor-pointer'
@@ -70,9 +71,14 @@ export function ScheduleInfo({ blockId, isPreview = false }: ScheduleInfoProps)
               </Badge>
             ) : null}
           </div>
-          {failedCount >= 100 && isDisabled && (
+          {failedCount >= MAX_CONSECUTIVE_FAILURES && isDisabled && (
             <p className='text-[12px] text-[var(--text-tertiary)]'>
-              Disabled after 100 consecutive failures
+              Disabled after {MAX_CONSECUTIVE_FAILURES} consecutive failures
+            </p>
+          )}
+          {redeployMutation.isError && (
+            <p className='text-[12px] text-[var(--text-error)]'>
+              Failed to redeploy. Please try again.
             </p>
           )}
         </div>

apps/sim/background/schedule-execution.ts

@@ -27,11 +27,10 @@ import { type ExecutionMetadata, ExecutionSnapshot } from '@/executor/execution/
 import type { ExecutionResult } from '@/executor/types'
 import { createEnvVarPattern } from '@/executor/utils/reference-validation'
 import { mergeSubblockState } from '@/stores/workflows/server-utils'
+import { MAX_CONSECUTIVE_FAILURES } from '@/triggers/constants'
 
 const logger = createLogger('TriggerScheduleExecution')
 
-const MAX_CONSECUTIVE_FAILURES = 100
-
 type WorkflowRecord = typeof workflow.$inferSelect
 type WorkflowScheduleUpdate = Partial<typeof workflowSchedule.$inferInsert>
 type ExecutionCoreResult = Awaited<ReturnType<typeof executeWorkflowCore>>

apps/sim/lib/webhooks/gmail-polling-service.ts

@@ -8,11 +8,10 @@ import { createLogger } from '@/lib/logs/console/logger'
 import { getOAuthToken, refreshAccessTokenIfNeeded } from '@/app/api/auth/oauth/utils'
 import type { GmailAttachment } from '@/tools/gmail/types'
 import { downloadAttachments, extractAttachmentInfo } from '@/tools/gmail/utils'
+import { MAX_CONSECUTIVE_FAILURES } from '@/triggers/constants'
 
 const logger = createLogger('GmailPollingService')
 
-const MAX_CONSECUTIVE_FAILURES = 100
-
 interface GmailWebhookConfig {
   labelIds: string[]
   labelFilterBehavior: 'INCLUDE' | 'EXCLUDE'

apps/sim/lib/webhooks/outlook-polling-service.ts

@@ -7,11 +7,10 @@ import { pollingIdempotency } from '@/lib/core/idempotency'
 import { getBaseUrl } from '@/lib/core/utils/urls'
 import { createLogger } from '@/lib/logs/console/logger'
 import { getOAuthToken, refreshAccessTokenIfNeeded } from '@/app/api/auth/oauth/utils'
+import { MAX_CONSECUTIVE_FAILURES } from '@/triggers/constants'
 
 const logger = createLogger('OutlookPollingService')
 
-const MAX_CONSECUTIVE_FAILURES = 100
-
 async function markWebhookFailed(webhookId: string) {
   try {
     const result = await db

apps/sim/lib/webhooks/rss-polling-service.ts

@@ -7,10 +7,9 @@ import { pollingIdempotency } from '@/lib/core/idempotency/service'
 import { createPinnedUrl, validateUrlWithDNS } from '@/lib/core/security/input-validation'
 import { getBaseUrl } from '@/lib/core/utils/urls'
 import { createLogger } from '@/lib/logs/console/logger'
+import { MAX_CONSECUTIVE_FAILURES } from '@/triggers/constants'
 
 const logger = createLogger('RssPollingService')
-
-const MAX_CONSECUTIVE_FAILURES = 100
 const MAX_GUIDS_TO_TRACK = 100 // Track recent guids to prevent duplicates
 
 interface RssWebhookConfig {

apps/sim/triggers/constants.ts

@@ -40,3 +40,9 @@ export const TRIGGER_RUNTIME_SUBBLOCK_IDS: string[] = [
   'testUrl',
   'testUrlExpiresAt',
 ]
+
+/**
+ * Maximum number of consecutive failures before a trigger (schedule/webhook) is auto-disabled.
+ * This prevents runaway errors from continuously executing failing workflows.
+ */
+export const MAX_CONSECUTIVE_FAILURES = 100