Fix StartNormalize Section (#457)

PeerDB-io · Sep 29, 2023 · 5e67e42 · 5e67e42
1 parent c55b004
commit 5e67e42
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
 	}