Call SetupReplConn in SyncFlow when one-sync disabled

PeerDB-io · Mar 15, 2024 · a0f0642 · a0f0642
1 parent bc4495a
commit a0f0642
Showing 1 changed file with 4 additions and 0 deletions.
diff --git 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 {