Method normalizeWorkspaceTurnRecord

src/node/services/taskService.ts:5690–5731

(
    record: WorkspaceTurnTaskHandleRecord
  )

  }

  private async normalizeWorkspaceTurnRecord(
    record: WorkspaceTurnTaskHandleRecord
  ): Promise<WorkspaceTurnTaskHandleRecord | null> {
    assert(record.ownerWorkspaceId.length > 0, "normalizeWorkspaceTurnRecord requires owner id");
    assert(record.handleId.length > 0, "normalizeWorkspaceTurnRecord requires handle id");

    // Older recovery skipped deferred stream-end history and could mark a completed workspace turn
    // interrupted. Re-check the durable child history anywhere handles are observed so task_list and
    // task_await agree on the self-healed terminal status.
    if (
      record.status === "interrupted" &&
      record.error === "Workspace turn interrupted after restart" &&
      (record.deferredMessageIds?.length ?? 0) > 0
    ) {
      const recovered = await this.recoverTerminalWorkspaceTurnFromHistory(record);
      if (recovered != null) {
        await this.taskHandleStore.upsertWorkspaceTurn(recovered);
        await this.cleanupDisposableWorkspaceTurn(recovered);
        const active = this.activeWorkspaceTurnHandleByWorkspaceId.get(record.workspaceId);
        if (
          active?.handleId === record.handleId &&
          active.ownerWorkspaceId === record.ownerWorkspaceId
        ) {
          this.activeWorkspaceTurnHandleByWorkspaceId.delete(record.workspaceId);
        }
        return await this.taskHandleStore.getWorkspaceTurn(
          record.ownerWorkspaceId,
          record.handleId
        );
      }
    }

    if (
      (record.status === "queued" || record.status === "starting" || record.status === "running") &&
      !(await this.isLiveWorkspaceTurn(record))
    ) {
      await this.settleStaleWorkspaceTurn(record);
      return await this.taskHandleStore.getWorkspaceTurn(record.ownerWorkspaceId, record.handleId);
    }

    return record;
  }

  async getWorkspaceTurnSnapshot(
    ownerWorkspaceId: string,