always Wait

PeerDB-io · Dec 24, 2024 · 620f5a8 · 620f5a8
1 parent 3eef689
commit 620f5a8
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/flow/activities/flowable.go b/flow/activities/flowable.go
@@ -338,10 +338,10 @@ func (a *FlowableActivity) SyncFlow(
 			}
 			logger.Error("failed to sync records", slog.Any("error", syncErr))
 			close(cdcState.syncDone)
-			return syncErr
+			return errors.Join(syncErr, cdcState.errGroup.Wait())
 		} else {
 			totalRecordsSynced += numRecordsSynced
-			logger.Info("Total records synced",
+			logger.Info("synced records",
 				slog.Int64("numRecordsSynced", numRecordsSynced), slog.Int64("totalRecordsSynced", totalRecordsSynced))
 
 			if options.NumberOfSyncs > 0 && currentSyncFlowNum >= options.NumberOfSyncs {