feat(scheduled-tasks): persist + run tasks via the job-schedule backend

Wire the calendar UI to the existing sourceType='job' workflow_schedule
backend instead of local component state, so tasks persist and actually
run as Sim agent invocations.

- schema: add contexts (@-mentions resolved into the run), excludedDates
  (per-occurrence deletes), and endsAt (recurrence end) to workflow_schedule
  (migration 0235)
- contracts/schedules: expose one-time `time`, contexts, endsAt on create;
  add the exclude_occurrence action; nullable cron in the create response
- orchestration: persist the new fields, honor exclusions + end boundary via
  a shared computeNextRunAt, add performExcludeOccurrence
- execution: forward contexts to /api/mothership/execute and recompute the
  next run through computeNextRunAt
- mothership/execute: accept + resolve contexts like the interactive chat path
- frontend: replace the local hook with React Query (create/update/delete +
  exclude-occurrence), expand recurrences into calendar occurrences, add the
  recurrence control (frequency + end) and the recurring this/all delete dialog

Author: waleedlatif1

apps/sim/app/api/mothership/execute/route.ts

@@ -6,6 +6,7 @@ import { mothershipExecuteContract } from '@/lib/api/contracts/mothership-chats'
 import { parseRequest } from '@/lib/api/server'
 import { checkInternalAuth } from '@/lib/auth/hybrid'
 import { buildIntegrationToolSchemas } from '@/lib/copilot/chat/payload'
+import { processContextsServer } from '@/lib/copilot/chat/process-contents'
 import { generateWorkspaceContext } from '@/lib/copilot/chat/workspace-context'
 import {
   MothershipStreamV1EventType,
@@ -22,6 +23,7 @@ import {
   getUserEntityPermissions,
   isWorkspaceAccessDeniedError,
 } from '@/lib/workspaces/permissions/utils'
+import type { ChatContext } from '@/stores/panel'
 
 export const maxDuration = 3600
 
@@ -102,6 +104,7 @@ export const POST = withRouteHandler(async (req: NextRequest) => {
       messageId: providedMessageId,
       requestId: providedRequestId,
       fileAttachments,
+      contexts,
       workflowId,
       executionId,
       userMetadata,
@@ -135,12 +138,22 @@ export const POST = withRouteHandler(async (req: NextRequest) => {
       workflowId,
       executionId,
     })
-    const [workspaceContext, integrationTools, userSkillTool, userPermission] = await Promise.all([
-      generateWorkspaceContext(workspaceId, userId),
-      buildIntegrationToolSchemas(userId, messageId, undefined, workspaceId),
-      buildUserSkillTool(workspaceId),
-      getUserEntityPermissions(userId, 'workspace', workspaceId).catch(() => null),
-    ])
+    const lastUserMessage = messages.filter((m) => m.role === 'user').at(-1)?.content
+    const [workspaceContext, integrationTools, userSkillTool, userPermission, agentContexts] =
+      await Promise.all([
+        generateWorkspaceContext(workspaceId, userId),
+        buildIntegrationToolSchemas(userId, messageId, undefined, workspaceId),
+        buildUserSkillTool(workspaceId),
+        getUserEntityPermissions(userId, 'workspace', workspaceId).catch(() => null),
+        // double-cast-allowed: the contract validates contexts as open kind/label objects; processContextsServer narrows on `kind` at runtime
+        processContextsServer(
+          contexts as unknown as ChatContext[] | undefined,
+          userId,
+          lastUserMessage,
+          workspaceId,
+          effectiveChatId
+        ).catch(() => []),
+      ])
     const requestPayload: Record<string, unknown> = {
       messages,
       responseFormat,
@@ -159,6 +172,7 @@ export const POST = withRouteHandler(async (req: NextRequest) => {
       ...(isE2BDocEnabled ? { docCompiler: 'python' } : {}),
       ...(userMetadata ? { userMetadata } : {}),
       ...(fileAttachments && fileAttachments.length > 0 ? { fileAttachments } : {}),
+      ...(agentContexts.length > 0 ? { contexts: agentContexts } : {}),
       ...(integrationTools.length > 0 ? { integrationTools } : {}),
       ...(userSkillTool ? { mothershipTools: [userSkillTool] } : {}),
       ...(userPermission ? { userPermission } : {}),

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

@@ -15,7 +15,11 @@ import { getSession } from '@/lib/auth'
 import { generateRequestId } from '@/lib/core/utils/request'
 import { withRouteHandler } from '@/lib/core/utils/with-route-handler'
 import { captureServerEvent } from '@/lib/posthog/server'
-import { performDeleteJob, performUpdateJob } from '@/lib/workflows/schedules/orchestration'
+import {
+  performDeleteJob,
+  performExcludeOccurrence,
+  performUpdateJob,
+} from '@/lib/workflows/schedules/orchestration'
 import { validateCronExpression } from '@/lib/workflows/schedules/utils'
 import { verifyWorkspaceMembership } from '@/app/api/workflows/utils'
 
@@ -185,6 +189,9 @@ export const PUT = withRouteHandler(
           lifecycle: validatedBody.lifecycle,
           maxRuns: validatedBody.maxRuns,
           cronExpression: validatedBody.cronExpression,
+          time: validatedBody.time,
+          endsAt: validatedBody.endsAt,
+          contexts: validatedBody.contexts,
           request,
         })
         if (!updateResult.success) {
@@ -199,6 +206,45 @@ export const PUT = withRouteHandler(
         return NextResponse.json({ message: 'Schedule updated successfully' })
       }
 
+      if (action === 'exclude_occurrence') {
+        if (schedule.sourceType !== 'job') {
+          return NextResponse.json(
+            { error: 'Only standalone job schedules have occurrences' },
+            { status: 400 }
+          )
+        }
+        if (!workspaceId) {
+          return NextResponse.json({ error: 'Job has no workspace' }, { status: 400 })
+        }
+
+        const excludeResult = await performExcludeOccurrence({
+          jobId: scheduleId,
+          workspaceId,
+          userId: session.user.id,
+          actorName: session.user.name,
+          actorEmail: session.user.email,
+          occurrence: validatedBody.occurrence,
+          request,
+        })
+        if (!excludeResult.success) {
+          return NextResponse.json(
+            { error: excludeResult.error || 'Failed to delete occurrence' },
+            {
+              status:
+                excludeResult.errorCode === 'not_found'
+                  ? 404
+                  : excludeResult.errorCode === 'validation'
+                    ? 400
+                    : 500,
+            }
+          )
+        }
+
+        logger.info(`[${requestId}] Excluded occurrence on job schedule: ${scheduleId}`)
+
+        return NextResponse.json({ message: 'Occurrence deleted successfully' })
+      }
+
       // reactivate
       if (schedule.status === 'active') {
         return NextResponse.json({ message: 'Schedule is already active' })

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

@@ -214,8 +214,19 @@ export const POST = withRouteHandler(async (req: NextRequest) => {
     )
     if (!parsed.success) return parsed.response
 
-    const { workspaceId, title, prompt, cronExpression, timezone, lifecycle, maxRuns, startDate } =
-      parsed.data.body
+    const {
+      workspaceId,
+      title,
+      prompt,
+      cronExpression,
+      time,
+      timezone,
+      lifecycle,
+      maxRuns,
+      endsAt,
+      startDate,
+      contexts,
+    } = parsed.data.body
 
     const permission = await verifyWorkspaceMembership(session.user.id, workspaceId)
     if (permission !== 'admin' && permission !== 'write') {
@@ -230,10 +241,13 @@ export const POST = withRouteHandler(async (req: NextRequest) => {
       title,
       prompt,
       cronExpression,
+      time,
       timezone,
       lifecycle,
       maxRuns,
+      endsAt,
       startDate,
+      contexts,
       request: req,
     })
     if (!result.success || !result.schedule) {

apps/sim/app/workspace/[workspaceId]/scheduled-tasks/components/task-delete-dialog/index.ts

@@ -0,0 +1 @@
+export { TaskDeleteDialog } from './task-delete-dialog'

apps/sim/app/workspace/[workspaceId]/scheduled-tasks/components/task-delete-dialog/task-delete-dialog.tsx

@@ -0,0 +1,98 @@
+'use client'
+
+import {
+  Calendar,
+  ChipConfirmModal,
+  ChipModal,
+  ChipModalBody,
+  ChipModalFooter,
+  ChipModalHeader,
+} from '@/components/emcn'
+import type { ScheduledTask } from '@/app/workspace/[workspaceId]/scheduled-tasks/utils/schedule-events'
+
+interface TaskDeleteDialogProps {
+  /** The task targeted for deletion, or `null` to keep the dialog closed. */
+  task: ScheduledTask | null
+  onClose: () => void
+  /** Delete just the targeted occurrence of a recurring task. */
+  onDeleteOccurrence: (task: ScheduledTask) => void
+  /** Delete a one-time task, or the entire recurring series. */
+  onDeleteSeries: (task: ScheduledTask) => void
+}
+
+/**
+ * Deletion confirmation for a scheduled task. A one-time task takes a single
+ * confirm; a recurring task offers the calendar-app choice between deleting
+ * this occurrence and deleting the whole series.
+ */
+export function TaskDeleteDialog({
+  task,
+  onClose,
+  onDeleteOccurrence,
+  onDeleteSeries,
+}: TaskDeleteDialogProps) {
+  if (task && !task.recurring) {
+    return (
+      <ChipConfirmModal
+        open
+        onOpenChange={(open) => {
+          if (!open) onClose()
+        }}
+        title='Delete scheduled task'
+        text='This task will be removed from the calendar and will not run.'
+        confirm={{
+          label: 'Delete',
+          onClick: () => {
+            onDeleteSeries(task)
+            onClose()
+          },
+        }}
+      />
+    )
+  }
+
+  return (
+    <ChipModal
+      open={task !== null}
+      onOpenChange={(open) => {
+        if (!open) onClose()
+      }}
+      size='sm'
+      srTitle='Delete recurring task'
+    >
+      {task && (
+        <>
+          <ChipModalHeader icon={Calendar} onClose={onClose}>
+            Delete recurring task
+          </ChipModalHeader>
+          <ChipModalBody>
+            <p className='px-2 text-[var(--text-body)] text-sm'>
+              This is a recurring task. Delete only this occurrence, or the entire series?
+            </p>
+          </ChipModalBody>
+          <ChipModalFooter
+            onCancel={onClose}
+            secondaryActions={[
+              {
+                label: 'This task',
+                variant: 'destructive',
+                onClick: () => {
+                  onDeleteOccurrence(task)
+                  onClose()
+                },
+              },
+            ]}
+            primaryAction={{
+              label: 'All tasks',
+              variant: 'destructive',
+              onClick: () => {
+                onDeleteSeries(task)
+                onClose()
+              },
+            }}
+          />
+        </>
+      )}
+    </ChipModal>
+  )
+}

apps/sim/app/workspace/[workspaceId]/scheduled-tasks/components/task-modal/index.ts

@@ -1 +1 @@
-export { type TaskDraft, TaskModal } from './task-modal'
+export { type TaskDraft, type TaskEditSeed, TaskModal } from './task-modal'