From 244c0953532f3601bea253bfa220a7cb26942113 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Philip=20Dub=C3=A9?= <serprex@users.noreply.github.com>
Date: Fri, 15 Mar 2024 19:42:19 +0000
Subject: [PATCH] Call SetupReplConn in SyncFlow when one-sync disabled (#1489)

---
 flow/activities/flowable.go | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/flow/activities/flowable.go b/flow/activities/flowable.go
index bf7f9fd678..4924627fd9 100644
--- a/flow/activities/flowable.go
+++ b/flow/activities/flowable.go
@@ -299,6 +299,10 @@ func (a *FlowableActivity) SyncFlow(
 			return nil, err
 		}
 		defer connectors.CloseConnector(ctx, srcConn)
+
+		if err := srcConn.SetupReplConn(ctx); err != nil {
+			return nil, err
+		}
 	} else {
 		srcConn, err = a.waitForCdcCache(ctx, sessionID)
 		if err != nil {