Function performDeleteJob

apps/sim/lib/workflows/schedules/orchestration.ts:468–507

(
  params: PerformDeleteJobParams
)

}

export async function performDeleteJob(
  params: PerformDeleteJobParams
): Promise<PerformScheduleResult> {
  const [job] = await db
    .select()
    .from(workflowSchedule)
    .where(activeJobCondition(params.jobId, params.workspaceId))
    .limit(1)

  if (!job)
    return { success: false, error: `Job not found: ${params.jobId}`, errorCode: 'not_found' }

  await db.delete(workflowSchedule).where(eq(workflowSchedule.id, params.jobId))
  recordAudit({
    workspaceId: params.workspaceId,
    actorId: params.userId,
    actorName: params.actorName ?? undefined,
    actorEmail: params.actorEmail ?? undefined,
    action: AuditAction.SCHEDULE_DELETED,
    resourceType: AuditResourceType.SCHEDULE,
    resourceId: params.jobId,
    resourceName: job.jobTitle ?? undefined,
    description: `Deleted job "${job.jobTitle ?? params.jobId}"`,
    metadata: {
      sourceType: job.sourceType,
      cronExpression: job.cronExpression,
      timezone: job.timezone,
    },
    request: params.request,
  })

  captureServerEvent(
    params.userId,
    'scheduled_task_deleted',
    { workspace_id: params.workspaceId },
    { groups: { workspace: params.workspaceId } }
  )

  return { success: true, schedule: job }
}

export async function performCompleteJob(
  params: PerformCompleteJobParams