From b052ebf9842db02524477bd9bc654aebac94b46d Mon Sep 17 00:00:00 2001 From: Tat Dat Duong Date: Tue, 20 May 2025 14:13:47 +0200 Subject: [PATCH] feat(sdk-js): add stream_resumable flag, that marks the stream as resumable --- libs/sdk-js/src/client.ts | 2 ++ libs/sdk-js/src/types.ts | 12 ++++++++++++ 2 files changed, 14 insertions(+) diff --git a/libs/sdk-js/src/client.ts b/libs/sdk-js/src/client.ts index 467c509ad..25745b3c6 100644 --- a/libs/sdk-js/src/client.ts +++ b/libs/sdk-js/src/client.ts @@ -894,6 +894,7 @@ export class RunsClient< metadata: payload?.metadata, stream_mode: payload?.streamMode, stream_subgraphs: payload?.streamSubgraphs, + stream_resumable: payload?.streamResumable, feedback_keys: payload?.feedbackKeys, assistant_id: assistantId, interrupt_before: payload?.interruptBefore, @@ -953,6 +954,7 @@ export class RunsClient< metadata: payload?.metadata, stream_mode: payload?.streamMode, stream_subgraphs: payload?.streamSubgraphs, + stream_resumable: payload?.streamResumable, assistant_id: assistantId, interrupt_before: payload?.interruptBefore, interrupt_after: payload?.interruptAfter, diff --git a/libs/sdk-js/src/types.ts b/libs/sdk-js/src/types.ts index 66d64620e..f9588f890 100644 --- a/libs/sdk-js/src/types.ts +++ b/libs/sdk-js/src/types.ts @@ -156,6 +156,12 @@ export interface RunsStreamPayload< */ streamSubgraphs?: TSubgraphs; + /** + * Whether the stream is considered resumable. + * If true, the stream can be resumed and replayed in its entirety even after disconnection. + */ + streamResumable?: boolean; + /** * Pass one or more feedbackKeys if you want to request short-lived signed URLs * for submitting feedback to LangSmith with this key for this run. @@ -173,6 +179,12 @@ export interface RunsCreatePayload extends RunsInvokePayload { * Stream output from subgraphs. By default, streams only the top graph. */ streamSubgraphs?: boolean; + + /** + * Whether the stream is considered resumable. + * If true, the stream can be resumed and replayed in its entirety even after disconnection. + */ + streamResumable?: boolean; } export interface CronsCreatePayload extends RunsCreatePayload {