Differential D8687 Diff 41072 python_modules/dagster-graphql/dagster_graphql/schema/pipelines/pipeline.py
Changeset View
Changeset View
Standalone View
Standalone View
python_modules/dagster-graphql/dagster_graphql/schema/pipelines/pipeline.py
| Show First 20 Lines • Show All 310 Lines • ▼ Show 20 Lines | class GrapheneIPipelineSnapshotMixin: | ||||
| runs = graphene.Field( | runs = graphene.Field( | ||||
| non_null_list(GraphenePipelineRun), | non_null_list(GraphenePipelineRun), | ||||
| cursor=graphene.String(), | cursor=graphene.String(), | ||||
| limit=graphene.Int(), | limit=graphene.Int(), | ||||
| ) | ) | ||||
| schedules = non_null_list(GrapheneSchedule) | schedules = non_null_list(GrapheneSchedule) | ||||
| sensors = non_null_list(GrapheneSensor) | sensors = non_null_list(GrapheneSensor) | ||||
| parent_snapshot_id = graphene.String() | parent_snapshot_id = graphene.String() | ||||
| graph_name = graphene.NonNull(graphene.String) | |||||
| class Meta: | class Meta: | ||||
| name = "IPipelineSnapshotMixin" | name = "IPipelineSnapshotMixin" | ||||
| def get_represented_pipeline(self): | def get_represented_pipeline(self): | ||||
| raise NotImplementedError() | raise NotImplementedError() | ||||
| def resolve_pipeline_snapshot_id(self, _graphene_info): | def resolve_pipeline_snapshot_id(self, _graphene_info): | ||||
| ▲ Show 20 Lines • Show All 112 Lines • ▼ Show 20 Lines | class GrapheneIPipelineSnapshotMixin: | ||||
| def resolve_parent_snapshot_id(self, _graphene_info): | def resolve_parent_snapshot_id(self, _graphene_info): | ||||
| lineage_snapshot = self.get_represented_pipeline().pipeline_snapshot.lineage_snapshot | lineage_snapshot = self.get_represented_pipeline().pipeline_snapshot.lineage_snapshot | ||||
| if lineage_snapshot: | if lineage_snapshot: | ||||
| return lineage_snapshot.parent_snapshot_id | return lineage_snapshot.parent_snapshot_id | ||||
| else: | else: | ||||
| return None | return None | ||||
| def resolve_graph_name(self, _graphene_info): | |||||
| return self.get_represented_pipeline().get_graph_name() | |||||
| class GrapheneIPipelineSnapshot(graphene.Interface): | class GrapheneIPipelineSnapshot(graphene.Interface): | ||||
| name = graphene.NonNull(graphene.String) | name = graphene.NonNull(graphene.String) | ||||
| description = graphene.String() | description = graphene.String() | ||||
| pipeline_snapshot_id = graphene.NonNull(graphene.String) | pipeline_snapshot_id = graphene.NonNull(graphene.String) | ||||
| dagster_types = non_null_list(GrapheneDagsterType) | dagster_types = non_null_list(GrapheneDagsterType) | ||||
| dagster_type_or_error = graphene.Field( | dagster_type_or_error = graphene.Field( | ||||
| graphene.NonNull(GrapheneDagsterTypeOrError), | graphene.NonNull(GrapheneDagsterTypeOrError), | ||||
| ▲ Show 20 Lines • Show All 104 Lines • Show Last 20 Lines | |||||