Function createRunCheckpoint

apps/sim/lib/copilot/async-runs/repository.ts:199–229

(input: {
  runId: string
  pendingToolCallId: string
  conversationSnapshot: Record<string, unknown>
  agentState: Record<string, unknown>
  providerRequest: Record<string, unknown>
})

}

async function createRunCheckpoint(input: {
  runId: string
  pendingToolCallId: string
  conversationSnapshot: Record<string, unknown>
  agentState: Record<string, unknown>
  providerRequest: Record<string, unknown>
}) {
  return withDbSpan(
    TraceSpan.CopilotAsyncRunsCreateRunCheckpoint,
    'INSERT',
    'copilot_run_checkpoints',
    {
      [TraceAttr.RunId]: input.runId,
      [TraceAttr.CopilotCheckpointPendingToolCallId]: input.pendingToolCallId,
    },
    async () => {
      const [checkpoint] = await db
        .insert(copilotRunCheckpoints)
        .values({
          runId: input.runId,
          pendingToolCallId: input.pendingToolCallId,
          conversationSnapshot: input.conversationSnapshot,
          agentState: input.agentState,
          providerRequest: input.providerRequest,
        })
        .returning()

      return checkpoint
    }
  )
}

export async function upsertAsyncToolCall(input: {
  runId?: string | null