Differential D4697 Diff 23458 python_modules/dagster/dagster/core/execution/plan/objects.py

Changeset View

Standalone View

python_modules/dagster/dagster/core/execution/plan/objects.py

from collections import namedtuple		from collections import namedtuple
from enum import Enum		from enum import Enum

from dagster import check		from dagster import check
from dagster.core.definitions import AssetMaterialization, Materialization, Solid, SolidHandle		from dagster.core.definitions import (
from dagster.core.definitions.events import EventMetadataEntry		Address,
		AssetMaterialization,
		EventMetadataEntry,
		Materialization,
		Solid,
		SolidHandle,
		)
from dagster.core.types.dagster_type import DagsterType		from dagster.core.types.dagster_type import DagsterType
from dagster.serdes import whitelist_for_serdes		from dagster.serdes import whitelist_for_serdes
from dagster.utils import merge_dicts		from dagster.utils import merge_dicts
from dagster.utils.error import SerializableErrorInfo		from dagster.utils.error import SerializableErrorInfo


@whitelist_for_serdes		@whitelist_for_serdes
class StepOutputHandle(namedtuple("_StepOutputHandle", "step_key output_name")):		class StepOutputHandle(namedtuple("_StepOutputHandle", "step_key output_name")):
▲ Show 20 Lines • Show All 69 Lines • ▼ Show 20 Lines	):
step_output_handle, "step_output_handle", StepOutputHandle		step_output_handle, "step_output_handle", StepOutputHandle
),		),
intermediate_materialization=check.opt_inst_param(		intermediate_materialization=check.opt_inst_param(
intermediate_materialization,		intermediate_materialization,
"intermediate_materialization",		"intermediate_materialization",
(AssetMaterialization, Materialization),		(AssetMaterialization, Materialization),
),		),
type_check_data=check.opt_inst_param(type_check_data, "type_check_data", TypeCheckData),		type_check_data=check.opt_inst_param(type_check_data, "type_check_data", TypeCheckData),
address=check.opt_str_param(address, "address"),		address=check.opt_inst_param(address, "address", Address),
version=check.opt_str_param(version, "version"),		version=check.opt_str_param(version, "version"),
)		)

@property		@property
def output_name(self):		def output_name(self):
return self.step_output_handle.output_name		return self.step_output_handle.output_name


▲ Show 20 Lines • Show All 182 Lines • Show Last 20 Lines