From 20380dd06ee718066e682b7ba9dda1c219206ee8 Mon Sep 17 00:00:00 2001 From: Amogh-Bharadwaj Date: Fri, 29 Sep 2023 23:22:13 +0530 Subject: [PATCH] returns for not supp err case --- 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 }