Changeset View
Changeset View
Standalone View
Standalone View
python_modules/dagster-graphql/dagster_graphql/schema/runs.py
| Show First 20 Lines • Show All 93 Lines • ▼ Show 20 Lines | def __init__(self, stats): | ||||
| expectationResults=stats.expectation_results, | expectationResults=stats.expectation_results, | ||||
| ) | ) | ||||
| class DauphinPipelineRun(dauphin.ObjectType): | class DauphinPipelineRun(dauphin.ObjectType): | ||||
| class Meta(object): | class Meta(object): | ||||
| name = "PipelineRun" | name = "PipelineRun" | ||||
| id = dauphin.NonNull(dauphin.ID) | |||||
| runId = dauphin.NonNull(dauphin.String) | runId = dauphin.NonNull(dauphin.String) | ||||
| # Nullable because of historical runs | # Nullable because of historical runs | ||||
| pipelineSnapshotId = dauphin.String() | pipelineSnapshotId = dauphin.String() | ||||
| status = dauphin.NonNull("PipelineRunStatus") | status = dauphin.NonNull("PipelineRunStatus") | ||||
| pipeline = dauphin.NonNull("PipelineReference") | pipeline = dauphin.NonNull("PipelineReference") | ||||
| pipelineName = dauphin.NonNull(dauphin.String) | pipelineName = dauphin.NonNull(dauphin.String) | ||||
| solidSelection = dauphin.List(dauphin.NonNull(dauphin.String)) | solidSelection = dauphin.List(dauphin.NonNull(dauphin.String)) | ||||
| stats = dauphin.NonNull("PipelineRunStatsOrError") | stats = dauphin.NonNull("PipelineRunStatsOrError") | ||||
| Show All 16 Lines | class DauphinPipelineRun(dauphin.ObjectType): | ||||
| assets = dauphin.non_null_list("Asset") | assets = dauphin.non_null_list("Asset") | ||||
| def __init__(self, pipeline_run): | def __init__(self, pipeline_run): | ||||
| super(DauphinPipelineRun, self).__init__( | super(DauphinPipelineRun, self).__init__( | ||||
| runId=pipeline_run.run_id, status=pipeline_run.status, mode=pipeline_run.mode | runId=pipeline_run.run_id, status=pipeline_run.status, mode=pipeline_run.mode | ||||
| ) | ) | ||||
| self._pipeline_run = check.inst_param(pipeline_run, "pipeline_run", PipelineRun) | self._pipeline_run = check.inst_param(pipeline_run, "pipeline_run", PipelineRun) | ||||
| def resolve_id(self, _): | |||||
| return self._pipeline_run.run_id | |||||
| def resolve_pipeline(self, graphene_info): | def resolve_pipeline(self, graphene_info): | ||||
| return get_pipeline_reference_or_raise(graphene_info, self._pipeline_run,) | return get_pipeline_reference_or_raise(graphene_info, self._pipeline_run,) | ||||
| def resolve_pipelineName(self, _graphene_info): | def resolve_pipelineName(self, _graphene_info): | ||||
| return self._pipeline_run.pipeline_name | return self._pipeline_run.pipeline_name | ||||
| def resolve_solidSelection(self, _graphene_info): | def resolve_solidSelection(self, _graphene_info): | ||||
| return self._pipeline_run.solid_selection | return self._pipeline_run.solid_selection | ||||
| ▲ Show 20 Lines • Show All 798 Lines • Show Last 20 Lines | |||||