Differential D6164 Diff 30546 python_modules/dagster-graphql/dagster_graphql/schema/pipelines/pipeline_run_stats.py
Changeset View
Changeset View
Standalone View
Standalone View
python_modules/dagster-graphql/dagster_graphql/schema/pipelines/pipeline_run_stats.py
- This file was added.
| import graphene | |||||
| from dagster import check | |||||
| from dagster.core.storage.pipeline_run import PipelineRunStatsSnapshot | |||||
| from ..errors import GraphenePythonError | |||||
| class GraphenePipelineRunStatsSnapshot(graphene.ObjectType): | |||||
| id = graphene.NonNull(graphene.String) | |||||
| runId = graphene.NonNull(graphene.String) | |||||
| stepsSucceeded = graphene.NonNull(graphene.Int) | |||||
| stepsFailed = graphene.NonNull(graphene.Int) | |||||
| materializations = graphene.NonNull(graphene.Int) | |||||
| expectations = graphene.NonNull(graphene.Int) | |||||
| startTime = graphene.Field(graphene.Float) | |||||
| endTime = graphene.Field(graphene.Float) | |||||
| class Meta: | |||||
| name = "PipelineRunStatsSnapshot" | |||||
| def __init__(self, stats): | |||||
| self._stats = check.inst_param(stats, "stats", PipelineRunStatsSnapshot) | |||||
| super().__init__( | |||||
| id="stats-" + self._stats.run_id, | |||||
| runId=self._stats.run_id, | |||||
| stepsSucceeded=self._stats.steps_succeeded, | |||||
| stepsFailed=self._stats.steps_failed, | |||||
| materializations=self._stats.materializations, | |||||
| expectations=self._stats.expectations, | |||||
| startTime=self._stats.start_time, | |||||
| endTime=self._stats.end_time, | |||||
| ) | |||||
| class GraphenePipelineRunStatsOrError(graphene.Union): | |||||
| class Meta: | |||||
| types = (GraphenePipelineRunStatsSnapshot, GraphenePythonError) | |||||
| name = "PipelineRunStatsOrError" | |||||