diff --git a/flow/activities/flowable.go b/flow/activities/flowable.go
index ca4223434a..464617c44b 100644
--- a/flow/activities/flowable.go
+++ b/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",