Differential D4785 Diff 25946 python_modules/dagster-graphql/dagster_graphql/implementation/fetch_runs.py
Changeset View
Changeset View
Standalone View
Standalone View
python_modules/dagster-graphql/dagster_graphql/implementation/fetch_runs.py
Show First 20 Lines • Show All 79 Lines • ▼ Show 20 Lines | def get_runs(graphene_info, filters, cursor=None, limit=None): | ||||
instance = graphene_info.context.instance | instance = graphene_info.context.instance | ||||
runs = [] | runs = [] | ||||
if filters and filters.run_ids and len(filters.run_ids) == 1: | if filters and filters.run_ids and len(filters.run_ids) == 1: | ||||
run = instance.get_run_by_id(filters.run_ids[0]) | run = instance.get_run_by_id(filters.run_ids[0]) | ||||
if run: | if run: | ||||
runs = [run] | runs = [run] | ||||
elif filters and ( | elif filters and ( | ||||
filters.pipeline_name or filters.tags or filters.status or filters.snapshot_id | filters.pipeline_name or filters.tags or filters.statuses or filters.snapshot_id | ||||
): | ): | ||||
runs = instance.get_runs(filters, cursor, limit) | runs = instance.get_runs(filters, cursor, limit) | ||||
else: | else: | ||||
runs = instance.get_runs(cursor=cursor, limit=limit) | runs = instance.get_runs(cursor=cursor, limit=limit) | ||||
return [graphene_info.schema.type_named("PipelineRun")(run) for run in runs] | return [graphene_info.schema.type_named("PipelineRun")(run) for run in runs] | ||||
▲ Show 20 Lines • Show All 62 Lines • Show Last 20 Lines |