fix SyncPg regression (#2370)

PeerDB-io · Dec 17, 2024 · 1573393 · 1573393
1 parent 55a7dc6
commit 1573393
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/flow/activities/flowable.go b/flow/activities/flowable.go
@@ -411,10 +411,11 @@ func (a *FlowableActivity) SyncPg(
 	config *protos.FlowConnectionConfigs,
 	options *protos.SyncFlowOptions,
 	sessionID string,
-) (int64, error) {
-	return syncCore(ctx, a, config, options, sessionID, nil,
+) (model.SyncRecordsResult, error) {
+	numRecords, err := syncCore(ctx, a, config, options, sessionID, nil,
 		connectors.CDCPullPgConnector.PullPg,
 		connectors.CDCSyncPgConnector.SyncPg)
+	return model.SyncRecordsResult{NumRecordsSynced: numRecords}, err
 }
 
 func (a *FlowableActivity) StartNormalize(