Skip to content

Commit

Permalink
Add even more logs
Browse files Browse the repository at this point in the history
  • Loading branch information
talsperre committed Jan 10, 2025
1 parent e461ac9 commit a9beb6a
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 0 deletions.
1 change: 1 addition & 0 deletions metaflow/plugins/metadata_providers/local.py
Original file line number Diff line number Diff line change
Expand Up @@ -303,6 +303,7 @@ def _read_metadata_value(file_path: str) -> dict:
# Read metadata and check value
metadata = _read_metadata_value(latest_file[0])
print(f"Metadata: {metadata}")
print("-" * 50)
if metadata.get("value") == field_value:
filtered_task_ids.append(task_id)

Expand Down
1 change: 1 addition & 0 deletions metaflow/task.py
Original file line number Diff line number Diff line change
Expand Up @@ -515,6 +515,7 @@ def run_step(
foreach_indices, foreach_indices_truncated, foreach_step_names = (
self._dynamic_runtime_metadata(foreach_stack)
)
print(f"Task id: {task_id}, foreach_stack: {foreach_stack}, foreach_indices: {foreach_indices}")
metadata.extend(
[
MetaDatum(
Expand Down

0 comments on commit a9beb6a

Please sign in to comment.