Method run

packages/core/src/pipes/pipes.ts:251–387

(
		options: RunOptions | RunOptionsStream,
	)

	public async run(options: RunOptionsStream): Promise<RunResponseStream>;
	public async run(options: RunOptions): Promise<RunResponse>;
	public async run(
		options: RunOptions | RunOptionsStream,
	): Promise<RunResponse | RunResponseStream> {
		// logger('pipe.run', this.pipe.name, 'RUN');

		const endpoint = '/v1/pipes/run';
		// logger('pipe.run.baseUrl.endpoint', getApiUrl() + endpoint);
		// logger('pipe.run.options');
		// logger(options, {depth: null, colors: true});

		const providerString = this.pipe.model.split(':')[0];
		const modelProvider = getProvider(providerString);
		const isAnthropic = modelProvider === ANTHROPIC;
		const hasTools = this.pipe.tools.length > 0;

		// For SDK
		// Run the given pipe name
		if (options.name) {
			this.pipe = {...this.pipe, name: options.name};
		}

		// For SDK
		// Run the pipe against the given Pipe API key
		if (options.apiKey) {
			this.request = new Request({
				apiKey: options.apiKey,
				baseUrl: this.baseUrl,
				...((options.llmKey && {llmKey: options.llmKey}) || {}),
			});
		}

		if (options.llmKey && !options.apiKey) {
			this.request = new Request({
				apiKey: this.entityApiKey,
				baseUrl: this.baseUrl,
				llmKey: options.llmKey,
			});
		}

		let stream = this.isStreamRequested(options);

		// Anthropic models don't support streaming with tools.
		if (isAnthropic && hasTools && stream) {
			this.warnIfToolsWithStream(stream);
			stream = false;
		}

		let runTools = options.runTools ?? true;

		// Do not run tools if they are explicitly provided in the options.
		if (options.tools && options.tools?.length) {
			runTools = false;
		}

		delete options.runTools;

		const body = {...options, stream};