Function recordRouterLifecycleEvent

packages/db/src/task-queue.ts:690–719

(
  task: QueuedTaskRecord,
  event: {
    type: string;
    actorType: Parameters<typeof recordAgentRouterEventSync>[0]["actorType"];
    actorId?: string;
    attemptId?: string;
    runtimeId?: string;
    provider?: Parameters<typeof recordAgentRouterEventSync>[0]["provider"];
    summary?: string;
    data?: Record<string, unknown>;
  },
)

}

function recordRouterLifecycleEvent(
  task: QueuedTaskRecord,
  event: {
    type: string;
    actorType: Parameters<typeof recordAgentRouterEventSync>[0]["actorType"];
    actorId?: string;
    attemptId?: string;
    runtimeId?: string;
    provider?: Parameters<typeof recordAgentRouterEventSync>[0]["provider"];
    summary?: string;
    data?: Record<string, unknown>;
  },
): void {
  if (!task.routerSessionId) {
    return;
  }
  recordAgentRouterEventSync({
    workspaceId: task.workspaceId,
    routerSessionId: task.routerSessionId,
    taskQueueId: task.id,
    attemptId: event.attemptId,
    type: event.type,
    actorType: event.actorType,
    actorId: event.actorId,
    runtimeId: event.runtimeId ?? task.runtimeId,
    provider: event.provider,
    summary: event.summary,
    data: event.data,
  });
}

function recordArtifactEvents(task: QueuedTaskRecord, resultJson: Record<string, unknown> | undefined): void {
  if (!resultJson) {