Method markWorkspaceTurnAccepted

src/node/services/taskService.ts:3066–3090

()

    }

    const markWorkspaceTurnAccepted = async () => {
      await this.workspaceTurnSettlementLocks.withLock(handleId, async () => {
        const current = await this.taskHandleStore.getWorkspaceTurn(ownerWorkspaceId, handleId);
        if (current?.workspaceId !== targetWorkspaceId) {
          throw new Error("Workspace turn was canceled before stream start");
        }
        if (current.turnId !== turnId) {
          throw new Error("Workspace turn correlation changed before stream start");
        }
        if (this.isTerminalWorkspaceTurnStatus(current.status)) {
          throw new Error(current.error ?? "Workspace turn was canceled before stream start");
        }
        if (current.status !== "running") {
          await this.taskHandleStore.upsertWorkspaceTurn({
            ...current,
            status: "running",
            updatedAt: getIsoNow(),
          });
        }
        this.activeWorkspaceTurnHandleByWorkspaceId.set(targetWorkspaceId, {
          handleId,
          ownerWorkspaceId,
        });
      });
    };

    const sendResult = await this.workspaceService.sendMessage(
      targetWorkspaceId,