File tree Expand file tree Collapse file tree 3 files changed +13
-18
lines changed Expand file tree Collapse file tree 3 files changed +13
-18
lines changed Original file line number Diff line number Diff line change @@ -710,22 +710,12 @@ export class AgentBlockHandler implements BlockHandler {
710
710
success : true ,
711
711
output : { } ,
712
712
logs : [ ] ,
713
- metadata : {
714
- duration : 0 ,
715
- startTime : new Date ( ) . toISOString ( ) ,
716
- } ,
717
- // Enrich with block metadata so the executor can route streaming correctly
718
- ...( block
719
- ? {
720
- // These fields are consumed only by the streaming path
721
- // and are safe to include here for routing purposes
722
- blockId : block . id as unknown as undefined ,
723
- blockType : block . metadata ?. id as unknown as undefined ,
724
- blockName : block . metadata ?. name as unknown as undefined ,
725
- isStreaming : true as unknown as undefined ,
726
- }
727
- : { isStreaming : true as unknown as undefined } ) ,
728
- } as any ,
713
+ metadata : { duration : 0 , startTime : new Date ( ) . toISOString ( ) } ,
714
+ isStreaming : true ,
715
+ blockId : block ?. id ,
716
+ blockType : block ?. metadata ?. id ,
717
+ blockName : block ?. metadata ?. name ,
718
+ } ,
729
719
}
730
720
}
731
721
Original file line number Diff line number Diff line change @@ -29,7 +29,6 @@ import type {
29
29
StreamingExecution ,
30
30
} from '@/executor/types'
31
31
import { streamingResponseFormatProcessor } from '@/executor/utils'
32
- // BlockType imported once at top
33
32
import type { SerializedBlock , SerializedWorkflow } from '@/serializer/types'
34
33
import { useExecutionStore } from '@/stores/execution/store'
35
34
import { useConsoleStore } from '@/stores/panel/console/store'
Original file line number Diff line number Diff line change @@ -185,7 +185,13 @@ export interface ExecutionResult {
185
185
*/
186
186
export interface StreamingExecution {
187
187
stream : ReadableStream // The streaming response for the UI to consume
188
- execution : ExecutionResult & { isStreaming ?: boolean } // The complete execution data for logging purposes
188
+ execution : ExecutionResult & {
189
+ // Streaming-specific metadata used by the UI routing path
190
+ isStreaming ?: boolean
191
+ blockId ?: string
192
+ blockType ?: string
193
+ blockName ?: string
194
+ } // The complete execution data for logging purposes
189
195
}
190
196
191
197
/**
You can’t perform that action at this time.
0 commit comments