From 5e67e42c44a2e37bf1f4e8b55760a6c60e3e4e15 Mon Sep 17 00:00:00 2001 From: Amogh Bharadwaj Date: Fri, 29 Sep 2023 23:37:53 +0530 Subject: [PATCH] Fix StartNormalize Section (#457) --- flow/activities/flowable.go | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/flow/activities/flowable.go b/flow/activities/flowable.go index 25b73e2ef9..193c9751e5 100644 --- 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 }