Changeset View
Changeset View
Standalone View
Standalone View
python_modules/dagster/dagster/cli/workspace/context.py
| Show First 20 Lines • Show All 103 Lines • ▼ Show 20 Lines | def has_external_pipeline(self, selector: PipelineSelector) -> bool: | ||||
| loc is not None | loc is not None | ||||
| and loc.has_repository(selector.repository_name) | and loc.has_repository(selector.repository_name) | ||||
| and loc.get_repository(selector.repository_name).has_external_pipeline( | and loc.get_repository(selector.repository_name).has_external_pipeline( | ||||
| selector.pipeline_name | selector.pipeline_name | ||||
| ) | ) | ||||
| ) | ) | ||||
| def get_full_external_pipeline(self, selector: PipelineSelector) -> ExternalPipeline: | def get_full_external_pipeline(self, selector: PipelineSelector) -> ExternalPipeline: | ||||
| return ( | return self.get_repository_location(selector.location_name).get_repository( | ||||
| self.get_repository_location(selector.location_name) | selector.repository_name | ||||
| .get_repository(selector.repository_name) | ).get_full_external_pipeline(selector.pipeline_name) | ||||
| .get_full_external_pipeline(selector.pipeline_name) | |||||
| ) | |||||
| def get_external_execution_plan( | def get_external_execution_plan( | ||||
| self, | self, | ||||
| external_pipeline: ExternalPipeline, | external_pipeline: ExternalPipeline, | ||||
| run_config: dict, | run_config: dict, | ||||
| mode: str, | mode: str, | ||||
| step_keys_to_execute: List[str], | step_keys_to_execute: List[str], | ||||
| known_state: KnownExecutionState, | known_state: KnownExecutionState, | ||||
| ) -> ExternalExecutionPlan: | ) -> ExternalExecutionPlan: | ||||
| return self.get_repository_location( | return self.get_repository_location(external_pipeline.handle.location_name).get_external_execution_plan( | ||||
| external_pipeline.handle.location_name | |||||
| ).get_external_execution_plan( | |||||
| external_pipeline=external_pipeline, | external_pipeline=external_pipeline, | ||||
| run_config=run_config, | run_config=run_config, | ||||
| mode=mode, | mode=mode, | ||||
| step_keys_to_execute=step_keys_to_execute, | step_keys_to_execute=step_keys_to_execute, | ||||
| known_state=known_state, | known_state=known_state, | ||||
| ) | ) | ||||
| def get_external_partition_config( | def get_external_partition_config( | ||||
| Show All 18 Lines | ) -> Union["ExternalPartitionTagsData", "ExternalPartitionExecutionErrorData"]: | ||||
| partition_name=partition_name, | partition_name=partition_name, | ||||
| ) | ) | ||||
| def get_external_partition_names( | def get_external_partition_names( | ||||
| self, repository_handle: RepositoryHandle, partition_set_name: str | self, repository_handle: RepositoryHandle, partition_set_name: str | ||||
| ) -> Union["ExternalPartitionNamesData", "ExternalPartitionExecutionErrorData"]: | ) -> Union["ExternalPartitionNamesData", "ExternalPartitionExecutionErrorData"]: | ||||
| return self.get_repository_location( | return self.get_repository_location( | ||||
| repository_handle.repository_location.name | repository_handle.repository_location.name | ||||
| ).get_external_partition_names(repository_handle, partition_set_name) | ).get_external_partition_names( | ||||
| repository_handle, partition_set_name | |||||
| ) | |||||
| def get_external_partition_set_execution_param_data( | def get_external_partition_set_execution_param_data( | ||||
| self, | self, | ||||
| repository_handle: RepositoryHandle, | repository_handle: RepositoryHandle, | ||||
| partition_set_name: str, | partition_set_name: str, | ||||
| partition_names: List[str], | partition_names: List[str], | ||||
| ) -> Union["ExternalPartitionSetExecutionParamData", "ExternalPartitionExecutionErrorData"]: | ) -> Union["ExternalPartitionSetExecutionParamData", "ExternalPartitionExecutionErrorData"]: | ||||
| return self.get_repository_location( | return self.get_repository_location( | ||||
| ▲ Show 20 Lines • Show All 92 Lines • Show Last 20 Lines | |||||