From 10f85ef47e6d69e20a675ae64ed576300ab8db84 Mon Sep 17 00:00:00 2001
From: Henry Heng <henryheng@flowiseai.com>
Date: Sun, 11 May 2025 18:43:28 +0800
Subject: [PATCH] Bugfix/Update agentflow v2 events to redis subscriber (#4415)

update agentflow v2 events to redis subscriber
---
 packages/server/src/queue/RedisEventSubscriber.ts | 9 +++++++++
 1 file changed, 9 insertions(+)

diff --git a/packages/server/src/queue/RedisEventSubscriber.ts b/packages/server/src/queue/RedisEventSubscriber.ts
index 81b18e3c..af78d280 100644
--- a/packages/server/src/queue/RedisEventSubscriber.ts
+++ b/packages/server/src/queue/RedisEventSubscriber.ts
@@ -85,6 +85,15 @@ export class RedisEventSubscriber {
             case 'nextAgent':
                 this.sseStreamer.streamNextAgentEvent(chatId, data)
                 break
+            case 'agentFlowEvent':
+                this.sseStreamer.streamAgentFlowEvent(chatId, data)
+                break
+            case 'agentFlowExecutedData':
+                this.sseStreamer.streamAgentFlowExecutedDataEvent(chatId, data)
+                break
+            case 'nextAgentFlow':
+                this.sseStreamer.streamNextAgentFlowEvent(chatId, data)
+                break
             case 'action':
                 this.sseStreamer.streamActionEvent(chatId, data)
                 break