revert

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)
 				}
 			}
 		}