Method retryEmptyStreamBeforeFailure

src/node/services/streamManager.ts:2363–2401

(
    workspaceId: WorkspaceId,
    streamInfo: WorkspaceStreamInfo,
    emptyStreamRecoveryAttempts: number
  )

  }

  private async retryEmptyStreamBeforeFailure(
    workspaceId: WorkspaceId,
    streamInfo: WorkspaceStreamInfo,
    emptyStreamRecoveryAttempts: number
  ): Promise<boolean> {
    if (emptyStreamRecoveryAttempts >= MAX_EMPTY_STREAM_RECOVERY_ATTEMPTS) {
      return false;
    }

    if (streamInfo.abortController.signal.aborted || streamInfo.softInterrupt.pending) {
      return false;
    }

    if (streamInfo.parts.length > 0) {
      return false;
    }

    const workspaceLog = this.getWorkspaceLogger(workspaceId, streamInfo);
    workspaceLog.warn("Retrying stream after empty-output completion", {
      messageId: streamInfo.messageId,
      model: streamInfo.model,
      nextAttempt: emptyStreamRecoveryAttempts + 1,
      maxAttempts: MAX_EMPTY_STREAM_RECOVERY_ATTEMPTS,
      previousResponseId: this.getOpenAIPreviousResponseId(streamInfo.request.providerOptions),
    });

    streamInfo.didRetryAfterEmptyOutput = true;
    await this.resetStreamStateForRetry(workspaceId, streamInfo, {
      preserveUsage: true,
      workspaceLog,
    });
    streamInfo.currentStepStartIndex = 0;
    streamInfo.streamResult = this.createStreamResult(
      streamInfo.request,
      streamInfo.abortController,
      streamInfo.stepTracker
    );
    return true;
  }

  /**
   * Processes a stream with guaranteed cleanup, regardless of success or failure