Function executeManageJob

apps/sim/lib/copilot/tools/handlers/jobs.ts:144–353

(
  params: Record<string, unknown>,
  context: ExecutionContext
)

}

export async function executeManageJob(
  params: Record<string, unknown>,
  context: ExecutionContext
): Promise<ToolCallResult> {
  const parsedParams = ManageJobParamsSchema.safeParse(params)
  if (!parsedParams.success) {
    return { success: false, error: 'Invalid manage job parameters' }
  }

  const rawParams: ManageJobParams = parsedParams.data
  const { operation, args } = rawParams

  if (!context.userId || !context.workspaceId) {
    return { success: false, error: 'Missing user or workspace context' }
  }

  switch (operation) {
    case 'create': {
      return executeCreateJob(
        {
          title: args?.title,
          prompt: args?.prompt,
          cron: args?.cron,
          time: args?.time,
          timezone: args?.timezone,
          lifecycle: args?.lifecycle,
          successCondition: args?.successCondition,
          maxRuns: args?.maxRuns,
        } as Record<string, unknown>,
        context
      )
    }

    case 'list': {
      try {
        const jobs = await db
          .select({
            id: workflowSchedule.id,
            jobTitle: workflowSchedule.jobTitle,
            prompt: workflowSchedule.prompt,
            cronExpression: workflowSchedule.cronExpression,
            timezone: workflowSchedule.timezone,
            status: workflowSchedule.status,
            lifecycle: workflowSchedule.lifecycle,
            successCondition: workflowSchedule.successCondition,
            maxRuns: workflowSchedule.maxRuns,
            runCount: workflowSchedule.runCount,
            nextRunAt: workflowSchedule.nextRunAt,
            lastRanAt: workflowSchedule.lastRanAt,
            sourceTaskName: workflowSchedule.sourceTaskName,
            createdAt: workflowSchedule.createdAt,
          })
          .from(workflowSchedule)
          .where(ACTIVE_JOB_CONDITION(context.workspaceId))

        return {
          success: true,
          output: {