Skip to content

Commit

Permalink
[instance] rm get_addresses_for_step_output_versions (#7601)
Browse files Browse the repository at this point in the history
  • Loading branch information
alangenfeld committed May 4, 2022
1 parent 6e467c5 commit 84cc1a4
Showing 1 changed file with 0 additions and 15 deletions.
15 changes: 0 additions & 15 deletions python_modules/dagster/dagster/core/instance/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -1984,21 +1984,6 @@ def __exit__(self, exception_type, exception_value, traceback):
if DagsterInstance._EXIT_STACK:
DagsterInstance._EXIT_STACK.close()

def get_addresses_for_step_output_versions(self, step_output_versions):
"""
For each given step output, finds whether an output exists with the given
version, and returns its address if it does.
Args:
step_output_versions (Dict[(str, StepOutputHandle), str]):
(pipeline name, step output handle) -> version.
Returns:
Dict[(str, StepOutputHandle), str]: (pipeline name, step output handle) -> address.
For each step output, an address if there is one and None otherwise.
"""
return self._event_storage.get_addresses_for_step_output_versions(step_output_versions)

# dagster daemon
def add_daemon_heartbeat(self, daemon_heartbeat: "DaemonHeartbeat"):
"""Called on a regular interval by the daemon"""
Expand Down

0 comments on commit 84cc1a4

Please sign in to comment.