Skip to content

Commit

Permalink
final fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
heavycrystal committed Nov 7, 2023
1 parent ed52703 commit 1f76f3e
Showing 1 changed file with 5 additions and 5 deletions.
10 changes: 5 additions & 5 deletions flow/workflows/qrep_flow.go
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down Expand Up @@ -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
Expand Down

0 comments on commit 1f76f3e

Please sign in to comment.