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 |