improvement(schedules): retries, concurrency limits (#4755)

* improvement(schedu
les): retries, concurrency limits

* improvement(schedules): remove stale generated migration

Drop the pre-merge generated 0213 migration so it can be regenerated after syncing with staging.

Co-authored-by: Cursor <cursoragent@cursor.com>

* address comments

* fix pinned version for lru cache

* retryable errs cleanup

---------

Co-authored-by: Cursor <cursoragent@cursor.com>

Author: icecrasher321

apps/sim/app/api/environment/route.ts

@@ -2,6 +2,7 @@ import { AuditAction, AuditResourceType, recordAudit } from '@sim/audit'
 import { db } from '@sim/db'
 import { environment } from '@sim/db/schema'
 import { createLogger } from '@sim/logger'
+import { toError } from '@sim/utils/errors'
 import { generateId } from '@sim/utils/id'
 import { eq } from 'drizzle-orm'
 import { type NextRequest, NextResponse } from 'next/server'
@@ -136,8 +137,8 @@ export const GET = withRouteHandler(async (request: Request) => {
     >
 
     return NextResponse.json({ data: decryptedVariables }, { status: 200 })
-  } catch (error: any) {
+  } catch (error) {
     logger.error(`[${requestId}] Environment fetch error`, error)
-    return NextResponse.json({ error: error.message }, { status: 500 })
+    return NextResponse.json({ error: toError(error).message }, { status: 500 })
   }
 })

apps/sim/app/api/schedules/[id]/route.ts

@@ -135,7 +135,7 @@ export const PUT = withRouteHandler(
 
         await db
           .update(workflowSchedule)
-          .set({ status: 'disabled', nextRunAt: null, updatedAt: new Date() })
+          .set({ status: 'disabled', nextRunAt: null, lastQueuedAt: null, updatedAt: new Date() })
           .where(and(eq(workflowSchedule.id, scheduleId), isNull(workflowSchedule.archivedAt)))
 
         logger.info(`[${requestId}] Disabled schedule: ${scheduleId}`)
@@ -220,7 +220,7 @@ export const PUT = withRouteHandler(
 
       await db
         .update(workflowSchedule)
-        .set({ status: 'active', failedCount: 0, updatedAt: now, nextRunAt })
+        .set({ status: 'active', failedCount: 0, infraRetryCount: 0, updatedAt: now, nextRunAt })
         .where(and(eq(workflowSchedule.id, scheduleId), isNull(workflowSchedule.archivedAt)))
 
       logger.info(`[${requestId}] Reactivated schedule: ${scheduleId}`)