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 |