feat(scheduled-tasks): migrate jobs to scheduled tasks and add scheduled tasks as a resource

Author: Sg312

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/hooks/stream/stream-helpers.ts

@@ -18,10 +18,10 @@ import {
   ManageCredentialOperation,
   ManageCustomTool,
   ManageCustomToolOperation,
-  ManageJob,
-  ManageJobOperation,
   ManageMcpTool,
   ManageMcpToolOperation,
+  ManageScheduledTask,
+  ManageScheduledTaskOperation,
   ManageSkill,
   ManageSkillOperation,
   MoveFolder,
@@ -345,17 +345,17 @@ export function resolveToolDisplayTitle(
     )
   }
 
-  if (name === ManageJob.id) {
+  if (name === ManageScheduledTask.id) {
     return resolveOperationDisplayTitle(
       args.operation,
       {
-        [ManageJobOperation.create]: 'Creating job',
-        [ManageJobOperation.get]: 'Getting job',
-        [ManageJobOperation.update]: 'Updating job',
-        [ManageJobOperation.delete]: 'Deleting job',
-        [ManageJobOperation.list]: 'Listing jobs',
+        [ManageScheduledTaskOperation.create]: 'Creating scheduled task',
+        [ManageScheduledTaskOperation.get]: 'Getting scheduled task',
+        [ManageScheduledTaskOperation.update]: 'Updating scheduled task',
+        [ManageScheduledTaskOperation.delete]: 'Deleting scheduled task',
+        [ManageScheduledTaskOperation.list]: 'Listing scheduled tasks',
       },
-      'Job action'
+      'Scheduled task action'
     )
   }
 
@@ -496,17 +496,17 @@ export function resolveStreamingToolDisplayTitle(
     )
   }
 
-  if (name === ManageJob.id) {
+  if (name === ManageScheduledTask.id) {
     return resolveOperationDisplayTitle(
       matchStreamingStringArg(streamingArgs, 'operation'),
       {
-        [ManageJobOperation.create]: 'Creating job',
-        [ManageJobOperation.get]: 'Getting job',
-        [ManageJobOperation.update]: 'Updating job',
-        [ManageJobOperation.delete]: 'Deleting job',
-        [ManageJobOperation.list]: 'Listing jobs',
+        [ManageScheduledTaskOperation.create]: 'Creating scheduled task',
+        [ManageScheduledTaskOperation.get]: 'Getting scheduled task',
+        [ManageScheduledTaskOperation.update]: 'Updating scheduled task',
+        [ManageScheduledTaskOperation.delete]: 'Deleting scheduled task',
+        [ManageScheduledTaskOperation.list]: 'Listing scheduled tasks',
       },
-      'Job action'
+      'Scheduled task action'
     )
   }
 

apps/sim/app/workspace/[workspaceId]/home/types.ts

@@ -12,7 +12,6 @@ import {
   GetPageContents,
   Glob,
   Grep,
-  Job,
   Knowledge,
   KnowledgeBase,
   ManageMcpTool,
@@ -21,6 +20,7 @@ import {
   OpenResource,
   Read as ReadTool,
   Research,
+  ScheduledTask,
   ScrapePage,
   SearchLibraryDocs,
   SearchOnline,
@@ -193,6 +193,8 @@ export const SUBAGENT_LABELS: Record<string, string> = {
   superagent: 'Superagent',
   run: 'Run Agent',
   agent: 'Tools Agent',
+  scheduled_task: 'Scheduled Task Agent',
+  // `job` retained as a backward-compat alias so historical transcripts still render a label.
   job: 'Job Agent',
   file: 'File Agent',
   media: 'Media Agent',
@@ -230,7 +232,8 @@ export const TOOL_UI_METADATA: Record<string, ToolTitleMetadata> = {
   [Knowledge.id]: { title: 'Knowledge Agent' },
   [KnowledgeBase.id]: { title: 'Managing knowledge base' },
   [Table.id]: { title: 'Table Agent' },
-  [Job.id]: { title: 'Job Agent' },
+  [ScheduledTask.id]: { title: 'Scheduled Task Agent' },
+  job: { title: 'Job Agent' },
   [Agent.id]: { title: 'Tools Agent' },
   custom_tool: { title: 'Creating tool' },
   [Research.id]: { title: 'Research Agent' },

apps/sim/background/schedule-execution.ts

@@ -1036,17 +1036,17 @@ function buildJobPrompt(jobRecord: {
     }
     parts.push('')
     parts.push(
-      'Use this history to avoid duplicate work. After completing meaningful work this run, call update_job_history to record what you did.'
+      'Use this history to avoid duplicate work. After completing meaningful work this run, call update_scheduled_task_history to record what you did.'
     )
   } else if (jobRecord.runCount > 0) {
     parts.push('')
     parts.push(
-      'No previous run history recorded. After completing meaningful work, call update_job_history to record what you did for future runs.'
+      'No previous run history recorded. After completing meaningful work, call update_scheduled_task_history to record what you did for future runs.'
     )
   } else {
     parts.push('')
     parts.push(
-      'This is the first run. After completing meaningful work, call update_job_history to record what you did so future runs have context.'
+      'This is the first run. After completing meaningful work, call update_scheduled_task_history to record what you did so future runs have context.'
     )
   }
 
@@ -1055,7 +1055,7 @@ function buildJobPrompt(jobRecord: {
     parts.push('COMPLETION PROTOCOL:')
     parts.push('This is a poll-until-done job. After executing the task above:')
     parts.push(
-      `- If the success condition is met, take the required action, then call complete_job(jobId: "${jobRecord.id}") to stop the job.`
+      `- If the success condition is met, take the required action, then call complete_scheduled_task(jobId: "${jobRecord.id}") to stop the scheduled task.`
     )
     parts.push(
       '- If the success condition is NOT met, do nothing extra. The job will run again on schedule.'
@@ -1285,7 +1285,7 @@ export async function executeJobInline(payload: JobExecutionPayload) {
       try {
         responseBody = await response.json()
         const toolCalls = responseBody?.toolCalls as Array<{ name?: string }> | undefined
-        wasCompletedByTool = toolCalls?.some((tc) => tc.name === 'complete_job') ?? false
+        wasCompletedByTool = toolCalls?.some((tc) => tc.name === 'complete_scheduled_task') ?? false
       } catch {
         if (timeoutController.isTimedOut()) {
           throw new Error(getTimeoutErrorMessage(null, timeoutController.timeoutMs))