Skip to content

Commit

Permalink
Update metadata API params
Browse files Browse the repository at this point in the history
  • Loading branch information
talsperre committed Nov 1, 2024
1 parent 0ef1087 commit ec43f14
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions metaflow/metadata/metadata.py
Original file line number Diff line number Diff line change
Expand Up @@ -674,16 +674,16 @@ def _register_system_metadata(self, run_id, step_name, task_id, attempt):

@classmethod
def _filter_tasks_by_metadata(
cls, flow_id, run_id, step_name, prev_step, field_name, field_value
cls, flow_id, run_id, step_name, query_step, field_name, field_value
):
raise NotImplementedError()

@classmethod
def filter_tasks_by_metadata(
cls, flow_id, run_id, step_name, prev_step, field_name, field_value
cls, flow_id, run_id, step_name, query_step, field_name, field_value
):
task_ids = cls._filter_tasks_by_metadata(
flow_id, run_id, step_name, prev_step, field_name, field_value
flow_id, run_id, step_name, query_step, field_name, field_value
)
return task_ids

Expand Down

0 comments on commit ec43f14

Please sign in to comment.