feat(scheduled-tasks): migrate jobs agent to scheduled tasks agent (#5090)

Author: Sg312

apps/sim/app/api/copilot/chat/resources/route.ts

@@ -17,6 +17,7 @@ import {
   createUnauthorizedResponse,
 } from '@/lib/copilot/request/http'
 import type { ChatResource, ResourceType } from '@/lib/copilot/resources/persistence'
+import { GENERIC_RESOURCE_TITLES } from '@/lib/copilot/resources/types'
 import { withRouteHandler } from '@/lib/core/utils/with-route-handler'
 
 const logger = createLogger('CopilotChatResourcesAPI')
@@ -27,10 +28,10 @@ const VALID_RESOURCE_TYPES = new Set<ResourceType>([
   'workflow',
   'knowledgebase',
   'folder',
+  'scheduledtask',
   'log',
   'integration',
 ])
-const GENERIC_TITLES = new Set(['Table', 'File', 'Workflow', 'Knowledge Base', 'Folder', 'Log'])
 
 export const POST = withRouteHandler(async (req: NextRequest) => {
   try {
@@ -76,7 +77,7 @@ export const POST = withRouteHandler(async (req: NextRequest) => {
 
     let merged: ChatResource[]
     if (prev) {
-      if (GENERIC_TITLES.has(prev.title) && !GENERIC_TITLES.has(resource.title)) {
+      if (GENERIC_RESOURCE_TITLES.has(prev.title) && !GENERIC_RESOURCE_TITLES.has(resource.title)) {
         merged = existing.map((r) =>
           `${r.type}:${r.id}` === key ? { ...r, title: resource.title } : r
         )

apps/sim/app/workspace/[workspaceId]/home/components/chat-context-kind-registry/chat-context-kind-registry.tsx

@@ -1,5 +1,6 @@
 import type { ReactNode } from 'react'
 import {
+  Calendar,
   Database,
   Folder as FolderIcon,
   Library,
@@ -79,6 +80,10 @@ export const CHAT_CONTEXT_KIND_REGISTRY: Record<ChatContextKind, ChatContextKind
     label: 'File folder',
     renderIcon: ({ className }) => <FolderIcon className={className} />,
   },
+  scheduledtask: {
+    label: 'Scheduled task',
+    renderIcon: ({ className }) => <Calendar className={className} />,
+  },
   past_chat: {
     label: 'Past chat',
     renderIcon: ({ className }) => <Task className={className} />,

apps/sim/app/workspace/[workspaceId]/home/components/message-content/utils.ts

@@ -51,6 +51,7 @@ const TOOL_ICONS: Record<string, IconComponent> = {
   knowledge: Database,
   knowledge_base: Database,
   table: TableIcon,
+  scheduled_task: Calendar,
   job: Calendar,
   agent: AgentIcon,
   custom_tool: Wrench,

apps/sim/app/workspace/[workspaceId]/home/components/mothership-view/components/add-resource-dropdown/add-resource-dropdown.tsx

@@ -1,6 +1,7 @@
 'use client'
 
 import { useMemo, useState } from 'react'
+import { truncate } from '@sim/utils/string'
 import {
   Button,
   DropdownMenu,
@@ -30,6 +31,7 @@ import { useFolders } from '@/hooks/queries/folders'
 import { useKnowledgeBasesQuery } from '@/hooks/queries/kb/knowledge'
 import { useLogsList } from '@/hooks/queries/logs'
 import { useMothershipChats } from '@/hooks/queries/mothership-chats'
+import { useWorkspaceSchedules } from '@/hooks/queries/schedules'
 import { useTablesList } from '@/hooks/queries/tables'
 import { useWorkflows } from '@/hooks/queries/workflows'
 import { useWorkspaceFileFolders } from '@/hooks/queries/workspace-file-folders'
@@ -77,6 +79,7 @@ export function useAvailableResources(
   const { data: folders = [] } = useFolders(workspaceId)
   const { data: fileFolders = [] } = useWorkspaceFileFolders(workspaceId)
   const { data: tasks = [] } = useMothershipChats(workspaceId)
+  const { data: schedules = [] } = useWorkspaceSchedules(workspaceId)
   const { data: logsData } = useLogsList(workspaceId, LOG_DROPDOWN_FILTERS)
   const logs = useMemo(() => (logsData?.pages ?? []).flatMap((page) => page.logs), [logsData])
 
@@ -155,6 +158,16 @@ export function useAvailableResources(
           isOpen: existingKeys.has(`task:${t.id}`),
         })),
       },
+      {
+        type: 'scheduledtask' as const,
+        items: schedules
+          .filter((s) => s.sourceType === 'job')
+          .map((s) => ({
+            id: s.id,
+            name: s.jobTitle || truncate(s.prompt ?? '', 40) || 'Scheduled Task',
+            isOpen: existingKeys.has(`scheduledtask:${s.id}`),
+          })),
+      },
       {
         type: 'log' as const,
         items: logs.map((log) => {
@@ -179,6 +192,7 @@ export function useAvailableResources(
     files,
     knowledgeBases,
     tasks,
+    schedules,
     logs,
     existingKeys,
     excludeTypes,

apps/sim/app/workspace/[workspaceId]/home/components/mothership-view/components/resource-content/resource-content.tsx

@@ -2,9 +2,11 @@
 
 import { lazy, memo, Suspense, useEffect, useMemo, useRef } from 'react'
 import { createLogger } from '@sim/logger'
+import { format } from 'date-fns'
 import { useRouter } from 'next/navigation'
 import { Button, PlayOutline, Skeleton, Tooltip } from '@/components/emcn'
 import {
+  Calendar,
   Download,
   FileX,
   Folder as FolderIcon,
@@ -24,6 +26,7 @@ import {
 import { canonicalWorkspaceFilePath } from '@/lib/copilot/vfs/path-utils'
 import { triggerFileDownload } from '@/lib/uploads/client/download'
 import { getFileExtension, getMimeTypeFromExtension } from '@/lib/uploads/utils/file-utils'
+import { parseCronToHumanReadable } from '@/lib/workflows/schedules/utils'
 import {
   FileViewer,
   type PreviewMode,
@@ -50,6 +53,7 @@ import { useUsageLimits } from '@/app/workspace/[workspaceId]/w/[workflowId]/com
 import { useWorkflowExecution } from '@/app/workspace/[workspaceId]/w/[workflowId]/hooks/use-workflow-execution'
 import { useFolders } from '@/hooks/queries/folders'
 import { useLogDetail } from '@/hooks/queries/logs'
+import { useWorkspaceSchedules } from '@/hooks/queries/schedules'
 import { downloadTableExport } from '@/hooks/queries/tables'
 import { useWorkflows } from '@/hooks/queries/workflows'
 import { useWorkspaceFiles } from '@/hooks/queries/workspace-files'
@@ -182,6 +186,15 @@ export const ResourceContent = memo(function ResourceContent({
     case 'folder':
       return <EmbeddedFolder key={resource.id} workspaceId={workspaceId} folderId={resource.id} />
 
+    case 'scheduledtask':
+      return (
+        <EmbeddedScheduledTask
+          key={resource.id}
+          workspaceId={workspaceId}
+          scheduleId={resource.id}
+        />
+      )
+
     case 'log':
       return (
         <EmbeddedLog
@@ -233,6 +246,8 @@ export function ResourceActions({ workspaceId, resource }: ResourceActionsProps)
       )
     case 'log':
       return <EmbeddedLogActions workspaceId={workspaceId} logId={resource.id} />
+    case 'scheduledtask':
+      return <EmbeddedScheduledTaskActions workspaceId={workspaceId} />
     case 'folder':
     case 'generic':
       return null
@@ -647,6 +662,141 @@ function EmbeddedFolder({ workspaceId, folderId }: EmbeddedFolderProps) {
   )
 }
 
+const SCHEDULE_STATUS_LABEL: Record<string, string> = {
+  active: 'Active',
+  disabled: 'Paused',
+  completed: 'Completed',
+}
+
+function formatScheduleInstant(iso: string | null): string {
+  if (!iso) return '—'
+  const date = new Date(iso)
+  return Number.isNaN(date.getTime()) ? '—' : format(date, "EEE, MMM d 'at' h:mm a")
+}
+
+interface ScheduledTaskFieldProps {
+  title: string
+  value: string
+}
+
+function ScheduledTaskField({ title, value }: ScheduledTaskFieldProps) {
+  return (
+    <div className='flex flex-col gap-1'>
+      <span className='text-[var(--text-muted)] text-caption'>{title}</span>
+      <span className='text-[var(--text-body)] text-small'>{value}</span>
+    </div>
+  )
+}
+
+interface EmbeddedScheduledTaskProps {
+  workspaceId: string
+  scheduleId: string
+}
+
+function EmbeddedScheduledTask({ workspaceId, scheduleId }: EmbeddedScheduledTaskProps) {
+  const { data: schedules = [], isLoading, isError } = useWorkspaceSchedules(workspaceId)
+  const schedule = useMemo(
+    () => schedules.find((s) => s.id === scheduleId),
+    [schedules, scheduleId]
+  )
+
+  if (isLoading && !schedule) return LOADING_SKELETON
+
+  if (!schedule) {
+    const heading = isError ? "Couldn't load scheduled task" : 'Scheduled task not found'
+    const detail = isError
+      ? 'Something went wrong loading this scheduled task. Try again.'
+      : 'This scheduled task may have been deleted'
+    return (
+      <div className='flex h-full flex-col items-center justify-center gap-3'>
+        <Calendar className='size-[32px] text-[var(--text-icon)]' />
+        <div className='flex flex-col items-center gap-1'>
+          <h2 className='font-medium text-[20px] text-[var(--text-primary)]'>{heading}</h2>
+          <p className='text-[var(--text-body)] text-small'>{detail}</p>
+        </div>
+      </div>
+    )
+  }
+
+  const title = schedule.jobTitle || schedule.prompt || 'Scheduled task'
+  const timing = schedule.cronExpression
+    ? parseCronToHumanReadable(schedule.cronExpression, schedule.timezone)
+    : 'Runs once'
+  const status = SCHEDULE_STATUS_LABEL[schedule.status] ?? schedule.status
+
+  return (
+    <div className='flex h-full flex-col gap-6 overflow-y-auto p-6'>
+      <div className='flex items-center gap-2'>
+        <Calendar className='size-[16px] flex-shrink-0 text-[var(--text-icon)]' />
+        <h2 className='truncate font-medium text-[16px] text-[var(--text-primary)]'>{title}</h2>
+      </div>
+
+      <div className='grid grid-cols-2 gap-4'>
+        <ScheduledTaskField title='Status' value={status} />
+        <ScheduledTaskField title='Schedule' value={timing} />
+        <ScheduledTaskField title='Next run' value={formatScheduleInstant(schedule.nextRunAt)} />
+        <ScheduledTaskField title='Last run' value={formatScheduleInstant(schedule.lastRanAt)} />
+      </div>
+
+      <div className='flex flex-col gap-1'>
+        <span className='text-[var(--text-muted)] text-caption'>Prompt</span>
+        <p className='whitespace-pre-wrap text-[var(--text-body)] text-small'>
+          {schedule.prompt || '—'}
+        </p>
+      </div>
+
+      {schedule.jobHistory && schedule.jobHistory.length > 0 && (
+        <div className='flex flex-col gap-2'>
+          <span className='text-[var(--text-muted)] text-caption'>Recent runs</span>
+          <div className='flex flex-col gap-2'>
+            {schedule.jobHistory.slice(0, 5).map((run, index) => (
+              <div
+                key={`${run.timestamp}-${index}`}
+                className='flex flex-col gap-1 rounded-[6px] bg-[var(--surface-4)] px-3 py-2'
+              >
+                <span className='text-[var(--text-tertiary)] text-caption'>
+                  {formatScheduleInstant(run.timestamp)}
+                </span>
+                <span className='text-[var(--text-body)] text-small'>{run.summary}</span>
+              </div>
+            ))}
+          </div>
+        </div>
+      )}
+    </div>
+  )
+}
+
+interface EmbeddedScheduledTaskActionsProps {
+  workspaceId: string
+}
+
+function EmbeddedScheduledTaskActions({ workspaceId }: EmbeddedScheduledTaskActionsProps) {
+  const router = useRouter()
+
+  const handleOpenScheduledTasks = () => {
+    router.push(`/workspace/${workspaceId}/scheduled-tasks`)
+  }
+
+  return (
+    <Tooltip.Root>
+      <Tooltip.Trigger asChild>
+        <Button
+          variant='subtle'
+          onClick={handleOpenScheduledTasks}
+          className={RESOURCE_TAB_ICON_BUTTON_CLASS}
+          aria-label='Open in scheduled tasks'
+        >
+          <SquareArrowUpRight className={RESOURCE_TAB_ICON_CLASS} />
+        </Button>
+      </Tooltip.Trigger>
+      <Tooltip.Content side='bottom'>
+        <p>Open in scheduled tasks</p>
+      </Tooltip.Content>
+    </Tooltip.Root>
+  )
+}
+
 interface EmbeddedLogProps {
   workspaceId: string
   logId: string

apps/sim/app/workspace/[workspaceId]/home/components/mothership-view/components/resource-registry/resource-registry.tsx

@@ -3,6 +3,7 @@
 import type { ElementType, ReactNode } from 'react'
 import type { QueryClient } from '@tanstack/react-query'
 import {
+  Calendar,
   Connections,
   Database,
   File as FileIcon,
@@ -23,6 +24,7 @@ import { getBareIconStyle, type StyleableIcon } from '@/blocks/icon-color'
 import { knowledgeKeys } from '@/hooks/queries/kb/knowledge'
 import { logKeys } from '@/hooks/queries/logs'
 import { mothershipChatKeys } from '@/hooks/queries/mothership-chats'
+import { scheduleKeys } from '@/hooks/queries/schedules'
 import { tableKeys } from '@/hooks/queries/tables'
 import { folderKeys } from '@/hooks/queries/utils/folder-keys'
 import { invalidateWorkflowLists } from '@/hooks/queries/utils/invalidate-workflow-lists'
@@ -183,6 +185,15 @@ export const RESOURCE_REGISTRY: Record<MothershipResourceType, ResourceTypeConfi
     ),
     renderDropdownItem: (props) => <DefaultDropdownItem {...props} />,
   },
+  scheduledtask: {
+    type: 'scheduledtask',
+    label: 'Scheduled Tasks',
+    icon: Calendar,
+    renderTabIcon: (_resource, className) => (
+      <Calendar className={cn(className, 'text-[var(--text-icon)]')} />
+    ),
+    renderDropdownItem: (props) => <IconDropdownItem {...props} icon={Calendar} />,
+  },
   log: {
     type: 'log',
     label: 'Logs',
@@ -241,6 +252,9 @@ const RESOURCE_INVALIDATORS: Record<
   task: (qc, wId) => {
     qc.invalidateQueries({ queryKey: mothershipChatKeys.list(wId) })
   },
+  scheduledtask: (qc, wId) => {
+    qc.invalidateQueries({ queryKey: scheduleKeys.list(wId) })
+  },
   log: (qc, _wId, id) => {
     qc.invalidateQueries({ queryKey: logKeys.details() })
     qc.invalidateQueries({ queryKey: logKeys.detail(id) })

apps/sim/app/workspace/[workspaceId]/home/components/user-input/components/chip-clipboard-codec.ts

@@ -27,6 +27,7 @@ const PORTABLE_KIND_TO_ID_FIELD = {
   file: 'fileId',
   folder: 'folderId',
   filefolder: 'fileFolderId',
+  scheduledtask: 'scheduleId',
   knowledge: 'knowledgeId',
   past_chat: 'chatId',
   workflow: 'workflowId',
@@ -207,6 +208,8 @@ export function chipLinkToContext(link: ParsedChipLink): ChatContext {
       return { kind: 'folder', folderId: link.id, label: link.label }
     case 'filefolder':
       return { kind: 'filefolder', fileFolderId: link.id, label: link.label }
+    case 'scheduledtask':
+      return { kind: 'scheduledtask', scheduleId: link.id, label: link.label }
     case 'knowledge':
       return { kind: 'knowledge', knowledgeId: link.id, label: link.label }
     case 'past_chat':

apps/sim/app/workspace/[workspaceId]/home/components/user-input/components/constants.ts

@@ -112,6 +112,7 @@ const RESOURCE_TO_CONTEXT: Record<
   task: (r) => ({ kind: 'past_chat', chatId: r.id, label: r.title }),
   log: (r) => ({ kind: 'logs', executionId: r.id, label: r.title }),
   integration: (r) => ({ kind: 'integration', blockType: r.id, label: r.title }),
+  scheduledtask: (r) => ({ kind: 'scheduledtask', scheduleId: r.id, label: r.title }),
   generic: (r) => ({ kind: 'docs', label: r.title }),
 }