Skip to content

Commit 3790e5c

Browse files
committed
fix lint error
1 parent f586af9 commit 3790e5c

1 file changed

Lines changed: 6 additions & 2 deletions

File tree

flow/cmd/handler.go

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -447,8 +447,12 @@ func (h *FlowRequestHandler) FlowStateChange(
447447
}
448448

449449
if req.FlowConfigUpdate != nil && req.FlowConfigUpdate.GetCdcFlowConfigUpdate() != nil &&
450-
// Don't allow config updates if the flow is already in a terminal state since it can lead to confusion where the config is updated but the flow is not reflecting those changes since it's already completed/failed
451-
(currState != protos.FlowStatus_STATUS_TERMINATED && currState != protos.FlowStatus_STATUS_TERMINATING && currState != protos.FlowStatus_STATUS_FAILED && currState != protos.FlowStatus_STATUS_COMPLETED) {
450+
// Don't allow config updates if the flow is already in a terminal state since it can lead to confusion
451+
// where the config is updated but the flow is not reflecting those changes since it's already completed/failed
452+
(currState != protos.FlowStatus_STATUS_TERMINATED &&
453+
currState != protos.FlowStatus_STATUS_TERMINATING &&
454+
currState != protos.FlowStatus_STATUS_FAILED &&
455+
currState != protos.FlowStatus_STATUS_COMPLETED) {
452456
if err := model.CDCDynamicPropertiesSignal.SignalClientWorkflow(
453457
ctx,
454458
h.temporalClient,

0 commit comments

Comments
 (0)