Skip to content

Commit 10f85ef

Browse files
authored
Bugfix/Update agentflow v2 events to redis subscriber (#4415)
update agentflow v2 events to redis subscriber
1 parent 0c3329b commit 10f85ef

File tree

1 file changed

+9
-0
lines changed

1 file changed

+9
-0
lines changed

packages/server/src/queue/RedisEventSubscriber.ts

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -85,6 +85,15 @@ export class RedisEventSubscriber {
8585
case 'nextAgent':
8686
this.sseStreamer.streamNextAgentEvent(chatId, data)
8787
break
88+
case 'agentFlowEvent':
89+
this.sseStreamer.streamAgentFlowEvent(chatId, data)
90+
break
91+
case 'agentFlowExecutedData':
92+
this.sseStreamer.streamAgentFlowExecutedDataEvent(chatId, data)
93+
break
94+
case 'nextAgentFlow':
95+
this.sseStreamer.streamNextAgentFlowEvent(chatId, data)
96+
break
8897
case 'action':
8998
this.sseStreamer.streamActionEvent(chatId, data)
9099
break

0 commit comments

Comments
 (0)