From 1f76f3e54b8a7349b56005dc61b3f70fa5cabd6a Mon Sep 17 00:00:00 2001 From: Kevin Biju Date: Wed, 8 Nov 2023 03:49:14 +0530 Subject: [PATCH] final fixes --- flow/workflows/qrep_flow.go | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/flow/workflows/qrep_flow.go b/flow/workflows/qrep_flow.go index 7ff248ec55..f20d17951e 100644 --- a/flow/workflows/qrep_flow.go +++ b/flow/workflows/qrep_flow.go @@ -17,10 +17,11 @@ import ( ) type QRepFlowExecution struct { - config *protos.QRepConfig - flowExecutionID string - logger log.Logger - runUUID string + config *protos.QRepConfig + flowExecutionID string + logger log.Logger + runUUID string + // being tracked for future workflow signalling childPartitionWorkflows []workflow.ChildWorkflowFuture // Current signalled state of the peer flow. activeSignal shared.CDCFlowSignal @@ -243,7 +244,6 @@ func (q *QRepFlowExecution) processPartitions( } } - // clear function requires go 1.21. why did this function not exist before go 1.21? q.childPartitionWorkflows = nil q.logger.Info("all partitions in batch processed") return nil