Changeset View
Changeset View
Standalone View
Standalone View
python_modules/dagster-graphql/dagster_graphql/schema/pipelines.py
| Show First 20 Lines • Show All 51 Lines • ▼ Show 20 Lines | class DauphinIPipelineSnapshotMixin(object): | ||||
| # get_represented_pipeline() | # get_represented_pipeline() | ||||
| # | # | ||||
| def get_represented_pipeline(self): | def get_represented_pipeline(self): | ||||
| raise NotImplementedError() | raise NotImplementedError() | ||||
| name = dauphin.NonNull(dauphin.String) | name = dauphin.NonNull(dauphin.String) | ||||
| description = dauphin.String() | description = dauphin.String() | ||||
| id = dauphin.NonNull(dauphin.ID) | |||||
| pipeline_snapshot_id = dauphin.NonNull(dauphin.String) | pipeline_snapshot_id = dauphin.NonNull(dauphin.String) | ||||
| dagster_types = dauphin.non_null_list("DagsterType") | dagster_types = dauphin.non_null_list("DagsterType") | ||||
| dagster_type_or_error = dauphin.Field( | dagster_type_or_error = dauphin.Field( | ||||
| dauphin.NonNull("DagsterTypeOrError"), | dauphin.NonNull("DagsterTypeOrError"), | ||||
| dagsterTypeName=dauphin.Argument(dauphin.NonNull(dauphin.String)), | dagsterTypeName=dauphin.Argument(dauphin.NonNull(dauphin.String)), | ||||
| ) | ) | ||||
| solids = dauphin.non_null_list("Solid") | solids = dauphin.non_null_list("Solid") | ||||
| modes = dauphin.non_null_list("Mode") | modes = dauphin.non_null_list("Mode") | ||||
| solid_handles = dauphin.Field( | solid_handles = dauphin.Field( | ||||
| dauphin.non_null_list("SolidHandle"), parentHandleID=dauphin.String() | dauphin.non_null_list("SolidHandle"), parentHandleID=dauphin.String() | ||||
| ) | ) | ||||
| solid_handle = dauphin.Field( | solid_handle = dauphin.Field( | ||||
| "SolidHandle", handleID=dauphin.Argument(dauphin.NonNull(dauphin.String)), | "SolidHandle", handleID=dauphin.Argument(dauphin.NonNull(dauphin.String)), | ||||
| ) | ) | ||||
| tags = dauphin.non_null_list("PipelineTag") | tags = dauphin.non_null_list("PipelineTag") | ||||
| runs = dauphin.Field( | runs = dauphin.Field( | ||||
| dauphin.non_null_list("PipelineRun"), cursor=dauphin.String(), limit=dauphin.Int(), | dauphin.non_null_list("PipelineRun"), cursor=dauphin.String(), limit=dauphin.Int(), | ||||
| ) | ) | ||||
| schedules = dauphin.non_null_list("ScheduleDefinition") | schedules = dauphin.non_null_list("ScheduleDefinition") | ||||
| parent_snapshot_id = dauphin.String() | parent_snapshot_id = dauphin.String() | ||||
| def resolve_pipeline_snapshot_id(self, _): | def resolve_pipeline_snapshot_id(self, _): | ||||
| return self.get_represented_pipeline().identifying_pipeline_snapshot_id | return self.get_represented_pipeline().identifying_pipeline_snapshot_id | ||||
| def resolve_id(self, _): | |||||
| return self.get_represented_pipeline().identifying_pipeline_snapshot_id | |||||
| def resolve_name(self, _): | def resolve_name(self, _): | ||||
| return self.get_represented_pipeline().name | return self.get_represented_pipeline().name | ||||
| def resolve_description(self, _): | def resolve_description(self, _): | ||||
| return self.get_represented_pipeline().description | return self.get_represented_pipeline().description | ||||
| def resolve_dagster_types(self, _graphene_info): | def resolve_dagster_types(self, _graphene_info): | ||||
| represented_pipeline = self.get_represented_pipeline() | represented_pipeline = self.get_represented_pipeline() | ||||
| ▲ Show 20 Lines • Show All 313 Lines • Show Last 20 Lines | |||||