Function performCompleteJob

apps/sim/lib/workflows/schedules/orchestration.ts:509–542

(
  params: PerformCompleteJobParams
)

}

export async function performCompleteJob(
  params: PerformCompleteJobParams
): 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' }
  if (job.status === 'completed') return { success: true, schedule: job, alreadyCompleted: true }

  const [updatedJob] = await db
    .update(workflowSchedule)
    .set({ status: 'completed', nextRunAt: null, updatedAt: new Date() })
    .where(and(eq(workflowSchedule.id, params.jobId), isNull(workflowSchedule.archivedAt)))
    .returning()

  recordAudit({
    workspaceId: params.workspaceId,
    actorId: params.userId,
    actorName: params.actorName ?? undefined,
    actorEmail: params.actorEmail ?? undefined,
    action: AuditAction.SCHEDULE_UPDATED,
    resourceType: AuditResourceType.SCHEDULE,
    resourceId: params.jobId,
    description: 'Completed job',
    metadata: { operation: 'complete' },
    request: params.request,
  })

  return { success: true, schedule: updatedJob, alreadyCompleted: false }
}