Skip to content

Commit b202de6

Browse files
committed
run graphql
1 parent d80e191 commit b202de6

File tree

3 files changed

+13
-0
lines changed

3 files changed

+13
-0
lines changed

js_modules/dagster-ui/packages/ui-core/src/graphql/schema.graphql

+1
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

js_modules/dagster-ui/packages/ui-core/src/graphql/types.ts

+5
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

python_modules/dagster-graphql/dagster_graphql/schema/pipelines/pipeline.py

+7
Original file line numberDiff line numberDiff line change
@@ -389,6 +389,7 @@ class GrapheneRun(graphene.ObjectType):
389389
hasDeletePermission = graphene.NonNull(graphene.Boolean)
390390
hasConcurrencyKeySlots = graphene.NonNull(graphene.Boolean)
391391
rootConcurrencyKeys = graphene.List(graphene.NonNull(graphene.String))
392+
allConcurrencyKeys = graphene.List(graphene.NonNull(graphene.String))
392393
hasUnconstrainedRootNodes = graphene.NonNull(graphene.Boolean)
393394
hasRunMetricsEnabled = graphene.NonNull(graphene.Boolean)
394395

@@ -622,6 +623,12 @@ def resolve_hasUnconstrainedRootNodes(self, graphene_info: ResolveInfo):
622623

623624
return False
624625

626+
def resolve_allConcurrencyKeys(self, graphene_info: ResolveInfo):
627+
if not self.dagster_run.run_op_concurrency:
628+
return None
629+
630+
return list(self.dagster_run.run_op_concurrency.all_pools)
631+
625632
def resolve_rootConcurrencyKeys(self, graphene_info: ResolveInfo):
626633
if not self.dagster_run.run_op_concurrency:
627634
return None

0 commit comments

Comments
 (0)