Skip to content

Commit 2907d2b

Browse files
committed
remove unneeded freshnessState resolver
1 parent aff2bd2 commit 2907d2b

File tree

4 files changed

+2
-82
lines changed

4 files changed

+2
-82
lines changed

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

Lines changed: 0 additions & 13 deletions
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

Lines changed: 0 additions & 33 deletions
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/asset_graph.py

Lines changed: 1 addition & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -98,10 +98,7 @@
9898
)
9999
from dagster_graphql.schema.entity_key import GrapheneAssetKey
100100
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
105102
from dagster_graphql.schema.freshness_policy import (
106103
GrapheneAssetFreshnessInfo,
107104
GrapheneFreshnessPolicy,
@@ -283,7 +280,6 @@ class GrapheneAssetNode(graphene.ObjectType):
283280
description = graphene.String()
284281
freshnessInfo = graphene.Field(GrapheneAssetFreshnessInfo)
285282
freshnessPolicy = graphene.Field(GrapheneFreshnessPolicy)
286-
freshnessState = graphene.Field(GrapheneFreshnessStateRecord)
287283
internalFreshnessPolicy = graphene.Field(GrapheneInternalFreshnessPolicy)
288284
autoMaterializePolicy = graphene.Field(GrapheneAutoMaterializePolicy)
289285
automationCondition = graphene.Field(GrapheneAutomationCondition)
@@ -1185,22 +1181,6 @@ def resolve_freshnessPolicy(
11851181
return GrapheneFreshnessPolicy(self._asset_node_snap.freshness_policy)
11861182
return None
11871183

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-
12041184
def resolve_internalFreshnessPolicy(
12051185
self, _graphene_info: ResolveInfo
12061186
) -> Optional[GrapheneInternalFreshnessPolicy]:

python_modules/dagster-graphql/dagster_graphql/schema/freshness.py

Lines changed: 1 addition & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -1,19 +1,5 @@
11
import graphene
2-
from dagster._core.definitions.freshness import (
3-
FreshnessState,
4-
InternalFreshnessPolicy,
5-
TimeWindowFreshnessPolicy,
6-
)
7-
8-
GrapheneFreshnessState = graphene.Enum.from_enum(FreshnessState)
9-
10-
11-
class GrapheneFreshnessStateRecord(graphene.ObjectType):
12-
class Meta:
13-
name = "FreshnessStateRecord"
14-
15-
state = graphene.NonNull(GrapheneFreshnessState)
16-
updatedAt = graphene.NonNull(graphene.Float)
2+
from dagster._core.definitions.freshness import InternalFreshnessPolicy, TimeWindowFreshnessPolicy
173

184

195
class GrapheneTimeWindowFreshnessPolicy(graphene.ObjectType):

0 commit comments

Comments
 (0)