Differential D4761 Diff 23634 python_modules/dagster-graphql/dagster_graphql/implementation/context.py
Changeset View
Changeset View
Standalone View
Standalone View
python_modules/dagster-graphql/dagster_graphql/implementation/context.py
| Show First 20 Lines • Show All 100 Lines • ▼ Show 20 Lines | ): | ||||
| mode=mode, | mode=mode, | ||||
| step_keys_to_execute=step_keys_to_execute, | step_keys_to_execute=step_keys_to_execute, | ||||
| ) | ) | ||||
| def get_external_partition_config(self, repository_handle, partition_set_name, partition_name): | def get_external_partition_config(self, repository_handle, partition_set_name, partition_name): | ||||
| return self._repository_locations[ | return self._repository_locations[ | ||||
| repository_handle.repository_location_handle.location_name | repository_handle.repository_location_handle.location_name | ||||
| ].get_external_partition_config( | ].get_external_partition_config( | ||||
| instance=self.instance, | |||||
| repository_handle=repository_handle, | repository_handle=repository_handle, | ||||
| partition_set_name=partition_set_name, | partition_set_name=partition_set_name, | ||||
| partition_name=partition_name, | partition_name=partition_name, | ||||
| ) | ) | ||||
| def get_external_partition_tags(self, repository_handle, partition_set_name, partition_name): | def get_external_partition_tags(self, repository_handle, partition_set_name, partition_name): | ||||
| return self._repository_locations[ | return self._repository_locations[ | ||||
| repository_handle.repository_location_handle.location_name | repository_handle.repository_location_handle.location_name | ||||
| ].get_external_partition_tags( | ].get_external_partition_tags( | ||||
| instance=self.instance, | |||||
| repository_handle=repository_handle, | repository_handle=repository_handle, | ||||
| partition_set_name=partition_set_name, | partition_set_name=partition_set_name, | ||||
| partition_name=partition_name, | partition_name=partition_name, | ||||
| ) | ) | ||||
| def get_external_partition_names(self, repository_handle, partition_set_name): | def get_external_partition_names(self, repository_handle, partition_set_name): | ||||
| return self._repository_locations[ | return self._repository_locations[ | ||||
| repository_handle.repository_location_handle.location_name | repository_handle.repository_location_handle.location_name | ||||
| ].get_external_partition_names(repository_handle, partition_set_name) | ].get_external_partition_names(self.instance, repository_handle, partition_set_name) | ||||
| def get_external_schedule_execution_data(self, repository_handle, schedule_name): | def get_external_schedule_execution_data(self, repository_handle, schedule_name): | ||||
| return self._repository_locations[ | return self._repository_locations[ | ||||
| repository_handle.repository_location_handle.location_name | repository_handle.repository_location_handle.location_name | ||||
| ].get_external_schedule_execution_data( | ].get_external_schedule_execution_data( | ||||
| self.instance, repository_handle, schedule_name, ScheduleExecutionDataMode.PREVIEW, None | self.instance, repository_handle, schedule_name, ScheduleExecutionDataMode.PREVIEW, None | ||||
| ) | ) | ||||
| def get_external_executable_param_data(self, repository_handle, executable_name): | def get_external_executable_param_data(self, repository_handle, executable_name): | ||||
| return self._repository_locations[ | return self._repository_locations[ | ||||
| repository_handle.repository_location_handle.location_name | repository_handle.repository_location_handle.location_name | ||||
| ].get_external_executable_params(self.instance, repository_handle, executable_name) | ].get_external_executable_params(self.instance, repository_handle, executable_name) | ||||
| def get_external_partition_set_execution_param_data( | def get_external_partition_set_execution_param_data( | ||||
| self, repository_handle, partition_set_name, partition_names | self, repository_handle, partition_set_name, partition_names | ||||
| ): | ): | ||||
| return self._repository_locations[ | return self._repository_locations[ | ||||
| repository_handle.repository_location_handle.location_name | repository_handle.repository_location_handle.location_name | ||||
| ].get_external_partition_set_execution_param_data( | ].get_external_partition_set_execution_param_data( | ||||
| instance=self.instance, | |||||
| repository_handle=repository_handle, | repository_handle=repository_handle, | ||||
| partition_set_name=partition_set_name, | partition_set_name=partition_set_name, | ||||
| partition_names=partition_names, | partition_names=partition_names, | ||||
| ) | ) | ||||
| def execute_plan( | def execute_plan( | ||||
| self, external_pipeline, run_config, pipeline_run, step_keys_to_execute, retries=None | self, external_pipeline, run_config, pipeline_run, step_keys_to_execute, retries=None | ||||
| ): | ): | ||||
| Show All 13 Lines | |||||