From 13aa46bb8359514cd4f7194f5b04203fc2d2b836 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Philip=20Dub=C3=A9?= Date: Tue, 12 Dec 2023 23:05:16 +0000 Subject: [PATCH] revert --- flow/workflows/cdc_flow.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/flow/workflows/cdc_flow.go b/flow/workflows/cdc_flow.go index 374290066b..9625681abe 100644 --- a/flow/workflows/cdc_flow.go +++ b/flow/workflows/cdc_flow.go @@ -8,7 +8,7 @@ import ( "github.com/PeerDB-io/peer-flow/generated/protos" "github.com/PeerDB-io/peer-flow/model" "github.com/PeerDB-io/peer-flow/shared" - "github.com/PeerDB-io/peer-flow/utils" + util "github.com/PeerDB-io/peer-flow/utils" "github.com/google/uuid" "github.com/hashicorp/go-multierror" "go.temporal.io/api/enums/v1" @@ -140,7 +140,7 @@ func (w *CDCFlowWorkflowExecution) receiveAndHandleSignalAsync(ctx workflow.Cont var signalVal shared.CDCFlowSignal ok := signalChan.ReceiveAsync(&signalVal) if ok { - state.ActiveSignal = utils.FlowSignalHandler(state.ActiveSignal, signalVal, w.logger) + state.ActiveSignal = util.FlowSignalHandler(state.ActiveSignal, signalVal, w.logger) } } @@ -326,7 +326,7 @@ func CDCFlowWorkflowWithConfig( // only place we block on receive, so signal processing is immediate ok, _ := signalChan.ReceiveWithTimeout(ctx, 1*time.Minute, &signalVal) if ok { - state.ActiveSignal = utils.FlowSignalHandler(state.ActiveSignal, signalVal, w.logger) + state.ActiveSignal = util.FlowSignalHandler(state.ActiveSignal, signalVal, w.logger) } } }