Skip to content

gql resolvers for asset freshness state and internal freshness policy #29319

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

Open
wants to merge 2 commits into
base: master
Choose a base branch
from

Conversation

anuthebananu
Copy link
Contributor

@anuthebananu anuthebananu commented Apr 16, 2025

Summary & Motivation

Adds two resolvers on GrapheneAssetNode - freshnessState and internalFreshnessPolicy

freshnessState is gated to be non-op in OSS since it relies on cloud daemon machinery.

How I Tested These Changes

unit tests / bk.

  • internalFreshnessPolicy has tests in this PR since it's fetched directly from the asset node snapshot
  • freshnessState relies on daemon machinery in cloud, tests will be in a PR in the cloud repo

Changelog

Insert changelog entry or delete this section.

Copy link
Contributor Author

This stack of pull requests is managed by Graphite. Learn more about stacking.

@anuthebananu anuthebananu changed the title wip - add freshness state to asset node graphql gql resolvers for asset freshness state and internal freshness policies Apr 16, 2025
@anuthebananu anuthebananu changed the title gql resolvers for asset freshness state and internal freshness policies gql resolvers for asset freshness state and internal freshness policy Apr 16, 2025
Copy link

Deploy preview for dagit-core-storybook ready!

✅ Preview
https://dagit-core-storybook-6wjh0ddt2-elementl.vercel.app
https://anurag-freshness-resolver-on-asset-node.core-storybook.dagster-docs.io

Built with commit aff2bd2.
This pull request is being automatically deployed with vercel-action

@anuthebananu anuthebananu marked this pull request as ready for review April 16, 2025 04:34
@@ -279,6 +283,8 @@ class GrapheneAssetNode(graphene.ObjectType):
description = graphene.String()
freshnessInfo = graphene.Field(GrapheneAssetFreshnessInfo)
freshnessPolicy = graphene.Field(GrapheneFreshnessPolicy)
freshnessState = graphene.Field(GrapheneFreshnessStateRecord)
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Should this be part of assetHealth ?

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants