diff --git a/flow/e2e/test_utils.go b/flow/e2e/test_utils.go index 3b36079f4c..5d1164760a 100644 --- a/flow/e2e/test_utils.go +++ b/flow/e2e/test_utils.go @@ -306,6 +306,7 @@ func RunQrepFlowWorkflow(env *testsuite.TestWorkflowEnvironment, config *protos. func RunXminFlowWorkflow(env *testsuite.TestWorkflowEnvironment, config *protos.QRepConfig) { state := peerflow.NewQRepFlowState() + state.LastPartition.PartitionId = uuid.New().String() time.Sleep(5 * time.Second) env.ExecuteWorkflow(peerflow.XminFlowWorkflow, config, state) }