Changeset View
Changeset View
Standalone View
Standalone View
python_modules/dagster/dagster/core/host_representation/external.py
| Show First 20 Lines • Show All 490 Lines • ▼ Show 20 Lines | def mode(self): | ||||
| return self._external_job_data.mode | return self._external_job_data.mode | ||||
| def get_external_origin(self): | def get_external_origin(self): | ||||
| return self._handle.get_external_origin() | return self._handle.get_external_origin() | ||||
| def get_external_origin_id(self): | def get_external_origin_id(self): | ||||
| return self.get_external_origin().get_id() | return self.get_external_origin().get_id() | ||||
| def get_default_job_state(self): | def get_default_job_state(self, _instance): | ||||
| from dagster.core.scheduler.job import JobState, JobStatus | from dagster.core.scheduler.job import JobState, JobStatus | ||||
| return JobState(self.get_external_origin(), JobType.SENSOR, JobStatus.STOPPED) | return JobState(self.get_external_origin(), JobType.SENSOR, JobStatus.STOPPED) | ||||
| class ExternalPartitionSet: | class ExternalPartitionSet: | ||||
| def __init__(self, external_partition_set_data, handle): | def __init__(self, external_partition_set_data, handle): | ||||
| self._external_partition_set_data = check.inst_param( | self._external_partition_set_data = check.inst_param( | ||||
| Show All 27 Lines | |||||