Differential D8675 Diff 40779 python_modules/dagster/dagster/core/host_representation/represented.py

Changeset View

Standalone View

python_modules/dagster/dagster/core/host_representation/represented.py

Show All 11 Lines	class RepresentedPipeline(ABC):
The name is "represented" because this is an in-memory representation of a pipeline.		The name is "represented" because this is an in-memory representation of a pipeline.
The representation of a pipeline could be referring to a pipeline resident in		The representation of a pipeline could be referring to a pipeline resident in
another process or could be referring to a historical view of the pipeline.		another process or could be referring to a historical view of the pipeline.
"""		"""

def __init__(self, pipeline_index):		def __init__(self, pipeline_index):
self._pipeline_index = check.inst_param(pipeline_index, "pipeline_index", PipelineIndex)		self._pipeline_index = check.inst_param(pipeline_index, "pipeline_index", PipelineIndex)

# Temporary method to allow for incrementally
# replacing pipeline index with the representation hierarchy
# Chosen for grepability
def get_pipeline_index_for_compat(self):
return self._pipeline_index

@property		@property
def name(self):		def name(self):
return self._pipeline_index.name		return self._pipeline_index.name

@property		@property
		def graph_name(self):
		return self._pipeline_index.graph_name

		@property
def description(self):		def description(self):
return self._pipeline_index.description		return self._pipeline_index.description

# Snapshot things		# Snapshot things

@abstractproperty		@abstractproperty
def computed_pipeline_snapshot_id(self):		def computed_pipeline_snapshot_id(self):
pass		pass
▲ Show 20 Lines • Show All 70 Lines • Show Last 20 Lines