Skip to content

Commit

Permalink
minor fix
Browse files Browse the repository at this point in the history
  • Loading branch information
madhur-ob committed May 24, 2024
1 parent 026f97a commit 56aa223
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions metaflow/runner/metaflow_runner.py
Original file line number Diff line number Diff line change
Expand Up @@ -247,7 +247,7 @@ def __enter__(self) -> "Runner":
async def __aenter__(self) -> "Runner":
return self

def __get_executing_run(self, tfp_metadata_pathspec, command_obj):
def __get_executing_run(self, tfp_runner_attribute, command_obj):
# When two 'Runner' executions are done sequentially i.e. one after the other
# the 2nd run kinda uses the 1st run's previously set metadata and
# environment variables.
Expand All @@ -259,7 +259,7 @@ def __get_executing_run(self, tfp_metadata_pathspec, command_obj):
clear_and_set_os_environ(self.old_env)

# Set the correct metadata from the runner_attribute file corresponding to this run.
content = read_from_file_when_ready(tfp_metadata_pathspec.name, timeout=10)
content = read_from_file_when_ready(tfp_runner_attribute.name, timeout=10)
metadata_for_flow, pathspec = content.split(":", maxsplit=1)
metadata(metadata_for_flow)

Expand Down

0 comments on commit 56aa223

Please sign in to comment.