returns for not supp err case

PeerDB-io · Sep 29, 2023 · 20380dd · 20380dd
1 parent c55b004
commit 20380dd
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/flow/activities/flowable.go b/flow/activities/flowable.go
@@ -326,9 +326,7 @@ func (a *FlowableActivity) StartNormalize(
 
 		err = a.CatalogMirrorMonitor.UpdateEndTimeForCDCBatch(ctx, input.FlowConnectionConfigs.FlowJobName,
 			lastSyncBatchID)
-		if err != nil {
-			return nil, err
-		}
+		return nil, err
 	} else if err != nil {
 		return nil, err
 	}