-
Notifications
You must be signed in to change notification settings - Fork 1.5k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
add pool graphql fields for runs #26964
base: prha/hoist_run_queue_config
Are you sure you want to change the base?
Conversation
Warning This pull request is not mergeable via GitHub because a downstack PR is open. Once all requirements are satisfied, merge this PR as a stack on Graphite.
This stack of pull requests is managed by Graphite. Learn more about stacking. |
Deploy preview for dagit-core-storybook ready! ✅ Preview Built with commit b58d918. |
d217d12
to
72da007
Compare
4dacceb
to
a8ac3e7
Compare
72da007
to
8782d96
Compare
a8ac3e7
to
3d16333
Compare
8782d96
to
5c83e2c
Compare
3d16333
to
a4ee6b4
Compare
5c83e2c
to
9e5e36d
Compare
a4ee6b4
to
ebd3269
Compare
9e5e36d
to
eb04b1b
Compare
ebd3269
to
a81756e
Compare
eb04b1b
to
d80e191
Compare
a81756e
to
b202de6
Compare
d80e191
to
e5ad4c3
Compare
b202de6
to
46e8b90
Compare
e5ad4c3
to
111c97c
Compare
46e8b90
to
591be98
Compare
111c97c
to
4e2eb36
Compare
591be98
to
1ef1cac
Compare
def resolve_allConcurrencyKeys(self, graphene_info: ResolveInfo): | ||
if not self.dagster_run.run_op_concurrency: | ||
return None | ||
|
||
return list(self.dagster_run.run_op_concurrency.all_pools) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
The schema defines allConcurrencyKeys
as a non-null array of strings ([String!]
), but this resolver returns None
when run_op_concurrency
is not present. To maintain type consistency, consider returning an empty list instead:
return [] if not self.dagster_run.run_op_concurrency else list(self.dagster_run.run_op_concurrency.all_pools)
Spotted by Graphite Reviewer
Is this helpful? React 👍 or 👎 to let us know.
@@ -389,6 +389,7 @@ class GrapheneRun(graphene.ObjectType): | |||
hasDeletePermission = graphene.NonNull(graphene.Boolean) | |||
hasConcurrencyKeySlots = graphene.NonNull(graphene.Boolean) | |||
rootConcurrencyKeys = graphene.List(graphene.NonNull(graphene.String)) | |||
allConcurrencyKeys = graphene.List(graphene.NonNull(graphene.String)) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
If this is a net-new field should we just call this allPools
from the outset?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
note naming comment
1ef1cac
to
b58d918
Compare
Summary & Motivation
Makes pool information available for the containing runs, to provide debugging information on the Run view, potentially the Run table.
How I Tested These Changes
BK