代码修改

frontend-web/src/core/threads/hooks.ts

@@ -30,11 +30,20 @@ export type ToolEndEvent = {
   data: unknown;
 };
 
-export type ThreadStreamOptions = {
-  threadId?: string | null | undefined;
-  context: LocalSettings["context"];
-  isMock?: boolean;
-  assistantId?: string;
+export type ThreadStreamOptions = {
+  threadId?: string | null | undefined;
+  context: LocalSettings["context"];
+  isMock?: boolean;
+  assistantId?: string;
+  /**
+   * Per-page run behaviour.  Most chats keep the SDK defaults; long-running
+   * workspace flows can opt into a resumable stream without changing global
+   * chat semantics.
+   */
+  runOptions?: {
+    onDisconnect?: "cancel" | "continue";
+    multitaskStrategy?: "reject" | "rollback" | "interrupt" | "enqueue";
+  };
   /** 额外写到新建 thread 的 metadata（与 agent_id 合并）。
    *  任务深链用 `{ taskId }` 把对话挂到任务下（1:N），列表按 metadata.taskId 过滤。 */
   threadMetadata?: Record<string, unknown>;
@@ -405,9 +414,10 @@ function lastHumanFromChatModelInput(input: unknown): string {
 export function useThreadStream({
   threadId,
   context,
-  isMock,
-  assistantId,
-  threadMetadata,
+  isMock,
+  assistantId,
+  runOptions,
+  threadMetadata,
   onStart,
   onFinish,
   onToolEnd,
@@ -1037,11 +1047,13 @@ export function useThreadStream({
           {
             messages: submittedMessages,
           },
-          {
-            threadId: threadId,
-            streamSubgraphs: true,
-            streamResumable: true,
-            config: {
+          {
+            threadId: threadId,
+            streamSubgraphs: true,
+            streamResumable: true,
+            onDisconnect: runOptions?.onDisconnect,
+            multitaskStrategy: runOptions?.multitaskStrategy,
+            config: {
               recursion_limit: 1000,
             },
             context: {
@@ -1076,7 +1088,7 @@ export function useThreadStream({
         sendInFlightRef.current = false;
       }
     },
-    [thread, _handleOnStart, t.uploads.uploadingFiles, context, localSettings.display.ragModeEnabled, queryClient],
+    [thread, _handleOnStart, t.uploads.uploadingFiles, context, localSettings.display.ragModeEnabled, queryClient, runOptions],
   );
 
   // Merge thread with optimistic messages for display