From 2cea075d9ee04609b3bb23790c6a823a8007058b Mon Sep 17 00:00:00 2001 From: Thomas Newton Date: Wed, 17 Jan 2024 09:51:00 +0000 Subject: [PATCH] Update test comments Signed-off-by: Thomas Newton --- flytepropeller/pkg/controller/workflow/executor_test.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flytepropeller/pkg/controller/workflow/executor_test.go b/flytepropeller/pkg/controller/workflow/executor_test.go index 93f5024668..9d2ffe6e62 100644 --- a/flytepropeller/pkg/controller/workflow/executor_test.go +++ b/flytepropeller/pkg/controller/workflow/executor_test.go @@ -521,6 +521,7 @@ func TestWorkflowExecutor_HandleFlyteWorkflow_Failing(t *testing.T) { h := &nodemocks.NodeHandler{} h.OnAbortMatch(mock.Anything, mock.Anything, mock.Anything).Return(nil) + // Mock handler marks start-node successfully completed but other nodes as failed startNodeMatcher := mock.MatchedBy(func(nodeExecContext fakeNodeExecContext) bool { return nodeExecContext.Node().IsStartNode() }) @@ -570,7 +571,6 @@ func TestWorkflowExecutor_HandleFlyteWorkflow_Failing(t *testing.T) { WorkflowSpec: &v1alpha1.WorkflowSpec{OnFailurePolicy: test.onFailurePolicy}, } if assert.NoError(t, json.Unmarshal(wJSON, w)) { - // For benchmark workflow, we will run into the first failure on round 6 for i := 0; i < test.expectedRoundsToFail; i++ { t.Run(fmt.Sprintf("Round[%d]", i), func(t *testing.T) {