Skip to content

Commit cad1c0b

Browse files
committed
Remove _iter_matching_tasks method
1 parent 115922e commit cad1c0b

File tree

1 file changed

+0
-25
lines changed

1 file changed

+0
-25
lines changed

metaflow/client/core.py

-25
Original file line numberDiff line numberDiff line change
@@ -1217,31 +1217,6 @@ def _get_matching_pathspecs(self, steps, metadata_key, metadata_pattern):
12171217
for task_pathspec in task_pathspecs:
12181218
yield task_pathspec
12191219

1220-
def _iter_matching_tasks(self, steps, metadata_key, metadata_pattern):
1221-
"""
1222-
Yield tasks from specified steps matching a foreach path pattern.
1223-
1224-
Parameters
1225-
----------
1226-
steps : List[str]
1227-
List of step names to search for tasks
1228-
pattern : str
1229-
Regex pattern to match foreach-indices metadata
1230-
1231-
Returns
1232-
-------
1233-
Iterator[Task]
1234-
Tasks matching the foreach path pattern
1235-
"""
1236-
flow_id, run_id, _, _ = self.path_components
1237-
1238-
for step in steps:
1239-
task_pathspecs = self._metaflow.metadata.filter_tasks_by_metadata(
1240-
flow_id, run_id, step.id, metadata_key, metadata_pattern
1241-
)
1242-
for task_pathspec in task_pathspecs:
1243-
yield Task(pathspec=task_pathspec, _namespace_check=False)
1244-
12451220
@property
12461221
def parent_task_pathspecs(self) -> Iterator[str]:
12471222
"""

0 commit comments

Comments
 (0)