Skip to content

Commit

Permalink
update backend metadata client test
Browse files Browse the repository at this point in the history
Signed-off-by: zazulam <m.zazula@gmail.com>
  • Loading branch information
zazulam committed Oct 9, 2024
1 parent 439843a commit d5eb5d3
Showing 1 changed file with 8 additions and 2 deletions.
10 changes: 8 additions & 2 deletions backend/src/v2/metadata/client_fake.go
Original file line number Diff line number Diff line change
Expand Up @@ -19,6 +19,7 @@ package metadata

import (
"context"

"github.com/kubeflow/pipelines/backend/src/v2/objectstore"

"github.com/kubeflow/pipelines/api/v2alpha1/go/pipelinespec"
Expand Down Expand Up @@ -64,10 +65,15 @@ func (c *FakeClient) GetPipelineFromExecution(ctx context.Context, id int64) (*P
return nil, nil
}

func (c *FakeClient) GetExecutionsInDAG(ctx context.Context, dag *DAG, pipeline *Pipeline) (executionsMap map[string]*Execution, err error) {
func (c *FakeClient) GetExecutionsInDAG(ctx context.Context, dag *DAG, pipeline *Pipeline, filter bool) (executionsMap map[string]*Execution, err error) {
return nil, nil
}

func (c *FakeClient) UpdateDAGExecutionsState(ctx context.Context, dag *DAG, pipeline *Pipeline) (err error) {
return nil
}
func (c *FakeClient) PutDAGExecutionState(ctx context.Context, executionID int64, state pb.Execution_State) (err error) {
return nil
}
func (c *FakeClient) GetEventsByArtifactIDs(ctx context.Context, artifactIds []int64) ([]*pb.Event, error) {
return nil, nil
}
Expand Down

0 comments on commit d5eb5d3

Please sign in to comment.