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 |