Add multi file error aggregation strategy

flyteorg · Oct 9, 2024 · fa982c3 · fa982c3
1 parent 5bb0351
commit fa982c3
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/flytepropeller/pkg/controller/nodes/task/k8s/plugin_manager_test.go b/flytepropeller/pkg/controller/nodes/task/k8s/plugin_manager_test.go
@@ -33,6 +33,7 @@ import (
 	"github.com/flyteorg/flyte/flytestdlib/contextutils"
 	"github.com/flyteorg/flyte/flytestdlib/promutils"
 	"github.com/flyteorg/flyte/flytestdlib/promutils/labeled"
+	"github.com/flyteorg/flyte/flytestdlib/storage"
 )
 
 type extendedFakeClient struct {
@@ -163,6 +164,10 @@ func (d *dummyOutputWriter) Put(ctx context.Context, reader io.OutputReader) err
 	return nil
 }
 
+func (d *dummyOutputWriter) GetErrorPath() storage.DataReference {
+	return ""
+}
+
 func getMockTaskContext(initPhase PluginPhase, wantPhase PluginPhase) pluginsCore.TaskExecutionContext {
 	taskExecutionContext := &pluginsCoreMock.TaskExecutionContext{}
 	taskExecutionContext.OnTaskExecutionMetadata().Return(getMockTaskExecutionMetadata())