Method settleStaleWorkspaceTurn

src/node/services/taskService.ts:6603–6646

(record: WorkspaceTurnTaskHandleRecord)

  }

  private async settleStaleWorkspaceTurn(record: WorkspaceTurnTaskHandleRecord): Promise<void> {
    if (record.status !== "queued" && record.status !== "starting" && record.status !== "running") {
      return;
    }
    const recovered = await this.recoverTerminalWorkspaceTurnFromHistory(record);
    if (recovered != null) {
      await this.settleWorkspaceTurn({
        record,
        next: recovered,
        waiterSettlement:
          recovered.status === "completed"
            ? { status: "completed", result: this.buildWorkspaceTurnWaitResult(recovered) }
            : { status: "error", error: new Error(recovered.error ?? "Workspace turn failed") },
      });
      return;
    }

    // Same-process deferred stream-ends can be observed before the final assistant message is
    // readable from history. Keep the handle alive in that narrow window; after restart the active
    // map is empty, so unrecoverable deferred handles still settle terminally instead of leaking.
    const active = this.activeWorkspaceTurnHandleByWorkspaceId.get(record.workspaceId);
    if (
      (record.deferredMessageIds?.length ?? 0) > 0 &&
      active?.handleId === record.handleId &&
      active.ownerWorkspaceId === record.ownerWorkspaceId
    ) {
      return;
    }

    const next: WorkspaceTurnTaskHandleRecord = {
      ...record,
      status: "interrupted",
      updatedAt: getIsoNow(),
      error: "Workspace turn interrupted after restart",
    };
    await this.settleWorkspaceTurn({
      record,
      next,
      waiterSettlement: {
        status: "error",
        error: new Error("Workspace turn interrupted after restart"),
      },
    });
  }

  private async countActiveWorkspaceTurns(
    records?: readonly WorkspaceTurnTaskHandleRecord[]