revert

flow/activities/flowable.go

@@ -332,13 +332,8 @@ func (a *FlowableActivity) SyncFlow(
 		}
 
 		if syncErr != nil {
-			if groupCtx.Err() != nil {
-				// need to return ctx.Err(), avoid returning syncErr that's wrapped context canceled
-				break
-			}
 			logger.Error("failed to sync records", slog.Any("error", syncErr))
-			close(cdcState.syncDone)
-			return errors.Join(syncErr, cdcState.errGroup.Wait())
+			break
 		} else {
 			totalRecordsSynced += numRecordsSynced
 			logger.Info("synced records",