Function executeCompleteJob

apps/sim/lib/copilot/tools/handlers/jobs.ts:355–395

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

}

export async function executeCompleteJob(
  params: Record<string, unknown>,
  context: ExecutionContext
): Promise<ToolCallResult> {
  const { jobId } = params as { jobId?: string }

  if (!jobId) {
    return { success: false, error: 'jobId is required' }
  }

  try {
    if (!context.workspaceId) {
      return { success: false, error: 'Missing workspace context' }
    }

    const result = await performCompleteJob({
      jobId,
      workspaceId: context.workspaceId,
      userId: context.userId,
    })
    if (!result.success) {
      return { success: false, error: result.error || 'Failed to complete job' }
    }
    if (result.alreadyCompleted) {
      return {
        success: true,
        output: { jobId, message: 'Job is already completed' },
      }
    }

    return {
      success: true,
      output: { jobId, message: 'Job marked as completed. No further executions will occur.' },
    }
  } catch (err) {
    logger.error('Failed to complete job', {
      error: toError(err).message,
    })
    return { success: false, error: 'Failed to complete job' }
  }
}

export async function executeUpdateJobHistory(
  params: Record<string, unknown>,