Differential D5137 Diff 25838 python_modules/dagster-graphql/dagster_graphql/schema/schedules/schedule_definition.py
Changeset View
Changeset View
Standalone View
Standalone View
python_modules/dagster-graphql/dagster_graphql/schema/schedules/schedule_definition.py
| Show All 26 Lines | class Meta(object): | ||||
| name = "ScheduleDefinitionsOrError" | name = "ScheduleDefinitionsOrError" | ||||
| types = (DauphinScheduleDefinitions, DauphinRepositoryNotFoundError, DauphinPythonError) | types = (DauphinScheduleDefinitions, DauphinRepositoryNotFoundError, DauphinPythonError) | ||||
| class DauphinScheduleDefinition(dauphin.ObjectType): | class DauphinScheduleDefinition(dauphin.ObjectType): | ||||
| class Meta(object): | class Meta(object): | ||||
| name = "ScheduleDefinition" | name = "ScheduleDefinition" | ||||
| id = dauphin.NonNull(dauphin.ID) | |||||
| name = dauphin.NonNull(dauphin.String) | name = dauphin.NonNull(dauphin.String) | ||||
| cron_schedule = dauphin.NonNull(dauphin.String) | cron_schedule = dauphin.NonNull(dauphin.String) | ||||
| pipeline_name = dauphin.NonNull(dauphin.String) | pipeline_name = dauphin.NonNull(dauphin.String) | ||||
| solid_selection = dauphin.List(dauphin.String) | solid_selection = dauphin.List(dauphin.String) | ||||
| mode = dauphin.NonNull(dauphin.String) | mode = dauphin.NonNull(dauphin.String) | ||||
| execution_timezone = dauphin.Field(dauphin.String) | execution_timezone = dauphin.Field(dauphin.String) | ||||
| schedule_state = dauphin.Field("ScheduleState") | schedule_state = dauphin.Field("ScheduleState") | ||||
| runConfigOrError = dauphin.Field("ScheduleRunConfigOrError") | runConfigOrError = dauphin.Field("ScheduleRunConfigOrError") | ||||
| partition_set = dauphin.Field("PartitionSet") | partition_set = dauphin.Field("PartitionSet") | ||||
| def resolve_id(self, _): | |||||
| return "%s:%s" % (self.name, self.pipeline_name) | |||||
| def resolve_runConfigOrError(self, graphene_info): | def resolve_runConfigOrError(self, graphene_info): | ||||
| return get_schedule_config(graphene_info, self._external_schedule) | return get_schedule_config(graphene_info, self._external_schedule) | ||||
| def resolve_partition_set(self, graphene_info): | def resolve_partition_set(self, graphene_info): | ||||
| if self._external_schedule.partition_set_name is None: | if self._external_schedule.partition_set_name is None: | ||||
| return None | return None | ||||
| repository = graphene_info.context.get_repository_location( | repository = graphene_info.context.get_repository_location( | ||||
| ▲ Show 20 Lines • Show All 50 Lines • Show Last 20 Lines | |||||