removed refs to gone var

PeerDB-io · Jan 15, 2024 · dda4975 · dda4975
1 parent 0e803df
commit dda4975
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 22 deletions.
diff --git a/flow/cmd/handler.go b/flow/cmd/handler.go
@@ -444,10 +444,6 @@ func (h *FlowRequestHandler) FlowStateChange(
 	if err != nil {
 		return nil, err
 	}
-	isCDCFlow, err := h.isCDCFlow(ctx, req.FlowJobName)
-	if err != nil {
-		return nil, err
-	}
 
 	if req.RequestedFlowState == protos.FlowStatus_STATUS_PAUSED &&
 		currState == protos.FlowStatus_STATUS_RUNNING {
@@ -464,13 +460,6 @@ func (h *FlowRequestHandler) FlowStateChange(
 		)
 	} else if req.RequestedFlowState == protos.FlowStatus_STATUS_RUNNING &&
 		currState == protos.FlowStatus_STATUS_PAUSED {
-		if isCDCFlow && req.FlowConfigUpdate.GetCdcFlowConfigUpdate() != nil {
-			err = h.attemptCDCFlowConfigUpdate(ctx, workflowID,
-				req.FlowConfigUpdate.GetCdcFlowConfigUpdate())
-			if err != nil {
-				return nil, err
-			}
-		}
 		err = h.temporalClient.SignalWorkflow(
 			ctx,
 			workflowID,

diff --git a/flow/cmd/mirror_status.go b/flow/cmd/mirror_status.go
@@ -385,14 +385,3 @@ func (h *FlowRequestHandler) updateWorkflowStatus(
 	}
 	return nil
 }
-
-func (h *FlowRequestHandler) attemptCDCFlowConfigUpdate(ctx context.Context,
-	workflowID string, cdcFlowConfigUpdate *protos.CDCFlowConfigUpdate,
-) error {
-	_, err := h.temporalClient.UpdateWorkflow(ctx, workflowID, "",
-		shared.CDCFlowConfigUpdate, cdcFlowConfigUpdate)
-	if err != nil {
-		return fmt.Errorf("failed to update config in CDC workflow with ID %s: %w", workflowID, err)
-	}
-	return nil
-}