|
98 | 98 | )
|
99 | 99 | from dagster_graphql.schema.entity_key import GrapheneAssetKey
|
100 | 100 | from dagster_graphql.schema.errors import GrapheneAssetNotFoundError
|
101 |
| -from dagster_graphql.schema.freshness import ( |
102 |
| - GrapheneFreshnessStateRecord, |
103 |
| - GrapheneInternalFreshnessPolicy, |
104 |
| -) |
| 101 | +from dagster_graphql.schema.freshness import GrapheneInternalFreshnessPolicy |
105 | 102 | from dagster_graphql.schema.freshness_policy import (
|
106 | 103 | GrapheneAssetFreshnessInfo,
|
107 | 104 | GrapheneFreshnessPolicy,
|
@@ -283,7 +280,6 @@ class GrapheneAssetNode(graphene.ObjectType):
|
283 | 280 | description = graphene.String()
|
284 | 281 | freshnessInfo = graphene.Field(GrapheneAssetFreshnessInfo)
|
285 | 282 | freshnessPolicy = graphene.Field(GrapheneFreshnessPolicy)
|
286 |
| - freshnessState = graphene.Field(GrapheneFreshnessStateRecord) |
287 | 283 | internalFreshnessPolicy = graphene.Field(GrapheneInternalFreshnessPolicy)
|
288 | 284 | autoMaterializePolicy = graphene.Field(GrapheneAutoMaterializePolicy)
|
289 | 285 | automationCondition = graphene.Field(GrapheneAutomationCondition)
|
@@ -1185,22 +1181,6 @@ def resolve_freshnessPolicy(
|
1185 | 1181 | return GrapheneFreshnessPolicy(self._asset_node_snap.freshness_policy)
|
1186 | 1182 | return None
|
1187 | 1183 |
|
1188 |
| - def resolve_freshnessState( |
1189 |
| - self, _graphene_info: ResolveInfo |
1190 |
| - ) -> Optional[GrapheneFreshnessStateRecord]: |
1191 |
| - if not _graphene_info.context.instance.dagster_observe_supported(): |
1192 |
| - return None |
1193 |
| - |
1194 |
| - freshness_state_record = _graphene_info.context.instance.get_entity_freshness_state( |
1195 |
| - self._asset_node_snap.asset_key |
1196 |
| - ) |
1197 |
| - if freshness_state_record: |
1198 |
| - return GrapheneFreshnessStateRecord( |
1199 |
| - state=freshness_state_record.freshness_state, |
1200 |
| - updatedAt=freshness_state_record.updated_at, |
1201 |
| - ) |
1202 |
| - return None |
1203 |
| - |
1204 | 1184 | def resolve_internalFreshnessPolicy(
|
1205 | 1185 | self, _graphene_info: ResolveInfo
|
1206 | 1186 | ) -> Optional[GrapheneInternalFreshnessPolicy]:
|
|
0 commit comments