Differential D5019 Diff 26207 python_modules/dagster/dagster/core/host_representation/external_data.py

Changeset View

Standalone View

python_modules/dagster/dagster/core/host_representation/external_data.py

Show First 20 Lines • Show All 227 Lines • ▼ Show 20 Lines	):
job_type=check.inst_param(job_type, "job_type", JobType),		job_type=check.inst_param(job_type, "job_type", JobType),
pipeline_name=check.str_param(pipeline_name, "pipeline_name"),		pipeline_name=check.str_param(pipeline_name, "pipeline_name"),
solid_selection=check.opt_nullable_list_param(solid_selection, "solid_selection", str),		solid_selection=check.opt_nullable_list_param(solid_selection, "solid_selection", str),
mode=check.opt_str_param(mode, "mode"),		mode=check.opt_str_param(mode, "mode"),
)		)


@whitelist_for_serdes		@whitelist_for_serdes
		class ExternalSensorExecutionData(
		namedtuple("_ExternalSensorExecutionData", "should_execute run_config tags")
		):
		def __new__(cls, should_execute=None, run_config=None, tags=None):
		return super(ExternalSensorExecutionData, cls).__new__(
		cls,
		should_execute=check.opt_bool_param(should_execute, "should_execute"),
		run_config=check.opt_dict_param(run_config, "run_config"),
		tags=check.opt_dict_param(tags, "tags", key_type=str, value_type=str),
		)


		@whitelist_for_serdes
		class ExternalSensorExecutionErrorData(namedtuple("_ExternalSensorExecutionErrorData", "error")):
		def __new__(cls, error):
		return super(ExternalSensorExecutionErrorData, cls).__new__(
		cls, error=check.opt_inst_param(error, "error", SerializableErrorInfo),
		)


		@whitelist_for_serdes
class ExternalExecutionParamsData(namedtuple("_ExternalExecutionParamsData", "run_config tags")):		class ExternalExecutionParamsData(namedtuple("_ExternalExecutionParamsData", "run_config tags")):
def __new__(cls, run_config=None, tags=None):		def __new__(cls, run_config=None, tags=None):
return super(ExternalExecutionParamsData, cls).__new__(		return super(ExternalExecutionParamsData, cls).__new__(
cls,		cls,
run_config=check.opt_dict_param(run_config, "run_config"),		run_config=check.opt_dict_param(run_config, "run_config"),
tags=check.opt_dict_param(tags, "tags", key_type=str, value_type=str),		tags=check.opt_dict_param(tags, "tags", key_type=str, value_type=str),
)		)

▲ Show 20 Lines • Show All 167 Lines • Show Last 20 Lines