feat(schedules): remove save button for schedules, couple schedule deployment with workflow deployment

Author: waleedlatif1

apps/docs/content/docs/en/triggers/schedule.mdx

@@ -5,7 +5,6 @@ title: Schedule
 import { Callout } from 'fumadocs-ui/components/callout'
 import { Tab, Tabs } from 'fumadocs-ui/components/tabs'
 import { Image } from '@/components/ui/image'
-import { Video } from '@/components/ui/video'
 
 The Schedule block automatically triggers workflows on a recurring schedule at specified intervals or times.
 
@@ -21,16 +20,16 @@ The Schedule block automatically triggers workflows on a recurring schedule at s
 
 ## Schedule Options
 
-Configure when your workflow runs using the dropdown options:
+Configure when your workflow runs:
 
 <Tabs items={['Simple Intervals', 'Cron Expressions']}>
   <Tab>
     <ul className="list-disc space-y-1 pl-6">
-      <li><strong>Every few minutes</strong>: 5, 15, 30 minute intervals</li>
-      <li><strong>Hourly</strong>: Every hour or every few hours</li>
-      <li><strong>Daily</strong>: Once or multiple times per day</li>
-      <li><strong>Weekly</strong>: Specific days of the week</li>
-      <li><strong>Monthly</strong>: Specific days of the month</li>
+      <li><strong>Every X Minutes</strong>: Run at minute intervals (1-1440)</li>
+      <li><strong>Hourly</strong>: Run at a specific minute each hour</li>
+      <li><strong>Daily</strong>: Run at a specific time each day</li>
+      <li><strong>Weekly</strong>: Run on a specific day and time each week</li>
+      <li><strong>Monthly</strong>: Run on a specific day and time each month</li>
     </ul>
   </Tab>
   <Tab>
@@ -43,24 +42,25 @@ Configure when your workflow runs using the dropdown options:
   </Tab>
 </Tabs>
 
-## Configuring Schedules
+## Activation
 
-When a workflow is scheduled:
-- The schedule becomes **active** and shows the next execution time
-- Click the **"Scheduled"** button to deactivate the schedule
-- Schedules automatically deactivate after **3 consecutive failures**
+Schedules are tied to workflow deployment:
 
-<div className="flex justify-center">
-  <Image
-    src="/static/blocks/schedule-2.png"
-    alt="Active Schedule Block"
-    width={500}
-    height={400}
-    className="my-6"
-  />
-</div>
+- **Deploy workflow** → Schedule becomes active and starts running
+- **Undeploy workflow** → Schedule is removed
+- **Redeploy workflow** → Schedule is recreated with current configuration
+
+<Callout>
+You must deploy your workflow for the schedule to start running. Configure the schedule block, then deploy from the toolbar.
+</Callout>
 
-## Disabled Schedules
+## Automatic Disabling
+
+Schedules automatically disable after **10 consecutive failures** to prevent runaway errors. When disabled:
+
+- A warning badge appears on the schedule block
+- The schedule stops executing
+- Click the badge to reactivate the schedule
 
 <div className="flex justify-center">
   <Image
@@ -72,8 +72,6 @@ When a workflow is scheduled:
   />
 </div>
 
-Disabled schedules show when they were last active. Click the **"Disabled"** badge to reactivate the schedule.
-
 <Callout>
-Schedule blocks cannot receive incoming connections and serve as pure workflow triggers.
-</Callout>
+Schedule blocks cannot receive incoming connections and serve as workflow entry points only.
+</Callout>

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

@@ -12,98 +12,19 @@ const logger = createLogger('ScheduleAPI')
 
 export const dynamic = 'force-dynamic'
 
-const scheduleActionEnum = z.enum(['reactivate', 'disable'])
-const scheduleStatusEnum = z.enum(['active', 'disabled'])
-
-const scheduleUpdateSchema = z
-  .object({
-    action: scheduleActionEnum.optional(),
-    status: scheduleStatusEnum.optional(),
-  })
-  .refine((data) => data.action || data.status, {
-    message: 'Either action or status must be provided',
-  })
+const scheduleUpdateSchema = z.object({
+  action: z.literal('reactivate'),
+})
 
 /**
- * Delete a schedule
- */
-export async function DELETE(
-  request: NextRequest,
-  { params }: { params: Promise<{ id: string }> }
-) {
-  const requestId = generateRequestId()
-
-  try {
-    const { id } = await params
-    logger.debug(`[${requestId}] Deleting schedule with ID: ${id}`)
-
-    const session = await getSession()
-    if (!session?.user?.id) {
-      logger.warn(`[${requestId}] Unauthorized schedule deletion attempt`)
-      return NextResponse.json({ error: 'Unauthorized' }, { status: 401 })
-    }
-
-    // Find the schedule and check ownership
-    const schedules = await db
-      .select({
-        schedule: workflowSchedule,
-        workflow: {
-          id: workflow.id,
-          userId: workflow.userId,
-          workspaceId: workflow.workspaceId,
-        },
-      })
-      .from(workflowSchedule)
-      .innerJoin(workflow, eq(workflowSchedule.workflowId, workflow.id))
-      .where(eq(workflowSchedule.id, id))
-      .limit(1)
-
-    if (schedules.length === 0) {
-      logger.warn(`[${requestId}] Schedule not found: ${id}`)
-      return NextResponse.json({ error: 'Schedule not found' }, { status: 404 })
-    }
-
-    const workflowRecord = schedules[0].workflow
-
-    // Check authorization - either the user owns the workflow or has write/admin workspace permissions
-    let isAuthorized = workflowRecord.userId === session.user.id
-
-    // If not authorized by ownership and the workflow belongs to a workspace, check workspace permissions
-    if (!isAuthorized && workflowRecord.workspaceId) {
-      const userPermission = await getUserEntityPermissions(
-        session.user.id,
-        'workspace',
-        workflowRecord.workspaceId
-      )
-      isAuthorized = userPermission === 'write' || userPermission === 'admin'
-    }
-
-    if (!isAuthorized) {
-      logger.warn(`[${requestId}] Unauthorized schedule deletion attempt for schedule: ${id}`)
-      return NextResponse.json({ error: 'Unauthorized' }, { status: 403 })
-    }
-
-    // Delete the schedule
-    await db.delete(workflowSchedule).where(eq(workflowSchedule.id, id))
-
-    logger.info(`[${requestId}] Successfully deleted schedule: ${id}`)
-    return NextResponse.json({ success: true }, { status: 200 })
-  } catch (error) {
-    logger.error(`[${requestId}] Error deleting schedule`, error)
-    return NextResponse.json({ error: 'Internal server error' }, { status: 500 })
-  }
-}
-
-/**
- * Update a schedule - can be used to reactivate a disabled schedule
+ * Reactivate a disabled schedule
  */
 export async function PUT(request: NextRequest, { params }: { params: Promise<{ id: string }> }) {
   const requestId = generateRequestId()
 
   try {
-    const { id } = await params
-    const scheduleId = id
-    logger.debug(`[${requestId}] Updating schedule with ID: ${scheduleId}`)
+    const { id: scheduleId } = await params
+    logger.debug(`[${requestId}] Reactivating schedule with ID: ${scheduleId}`)
 
     const session = await getSession()
     if (!session?.user?.id) {
@@ -115,13 +36,9 @@ export async function PUT(request: NextRequest, { params }: { params: Promise<{
     const validation = scheduleUpdateSchema.safeParse(body)
 
     if (!validation.success) {
-      const firstError = validation.error.errors[0]
-      logger.warn(`[${requestId}] Validation error:`, firstError)
-      return NextResponse.json({ error: firstError.message }, { status: 400 })
+      return NextResponse.json({ error: 'Invalid request body' }, { status: 400 })
     }
 
-    const { action, status: requestedStatus } = validation.data
-
     const [schedule] = await db
       .select({
         id: workflowSchedule.id,
@@ -164,57 +81,29 @@ export async function PUT(request: NextRequest, { params }: { params: Promise<{
       return NextResponse.json({ error: 'Not authorized to modify this schedule' }, { status: 403 })
     }
 
-    if (action === 'reactivate' || (requestedStatus && requestedStatus === 'active')) {
-      if (schedule.status === 'active') {
-        return NextResponse.json({ message: 'Schedule is already active' }, { status: 200 })
-      }
-
-      const now = new Date()
-      const nextRunAt = new Date(now.getTime() + 60 * 1000) // Schedule to run in 1 minute
-
-      await db
-        .update(workflowSchedule)
-        .set({
-          status: 'active',
-          failedCount: 0,
-          updatedAt: now,
-          nextRunAt,
-        })
-        .where(eq(workflowSchedule.id, scheduleId))
+    if (schedule.status === 'active') {
+      return NextResponse.json({ message: 'Schedule is already active' }, { status: 200 })
+    }
 
-      logger.info(`[${requestId}] Reactivated schedule: ${scheduleId}`)
+    const now = new Date()
+    const nextRunAt = new Date(now.getTime() + 60 * 1000) // Schedule to run in 1 minute
 
-      return NextResponse.json({
-        message: 'Schedule activated successfully',
+    await db
+      .update(workflowSchedule)
+      .set({
+        status: 'active',
+        failedCount: 0,
+        updatedAt: now,
         nextRunAt,
       })
-    }
-
-    if (action === 'disable' || (requestedStatus && requestedStatus === 'disabled')) {
-      if (schedule.status === 'disabled') {
-        return NextResponse.json({ message: 'Schedule is already disabled' }, { status: 200 })
-      }
-
-      const now = new Date()
-
-      await db
-        .update(workflowSchedule)
-        .set({
-          status: 'disabled',
-          updatedAt: now,
-          nextRunAt: null, // Clear next run time when disabled
-        })
-        .where(eq(workflowSchedule.id, scheduleId))
-
-      logger.info(`[${requestId}] Disabled schedule: ${scheduleId}`)
+      .where(eq(workflowSchedule.id, scheduleId))
 
-      return NextResponse.json({
-        message: 'Schedule disabled successfully',
-      })
-    }
+    logger.info(`[${requestId}] Reactivated schedule: ${scheduleId}`)
 
-    logger.warn(`[${requestId}] Unsupported update action for schedule: ${scheduleId}`)
-    return NextResponse.json({ error: 'Unsupported update action' }, { status: 400 })
+    return NextResponse.json({
+      message: 'Schedule activated successfully',
+      nextRunAt,
+    })
   } catch (error) {
     logger.error(`[${requestId}] Error updating schedule`, error)
     return NextResponse.json({ error: 'Failed to update schedule' }, { status: 500 })