fix bug in fetch_assets.get_asset_nodes_by_asset_key (#7063)

dagster-io · Mar 16, 2022 · b3e776b · b3e776b
1 parent 0f61c12
commit b3e776b
Showing 1 changed file with 1 addition and 4 deletions.
diff --git a/python_modules/dagster-graphql/dagster_graphql/implementation/fetch_assets.py b/python_modules/dagster-graphql/dagster_graphql/implementation/fetch_assets.py
@@ -69,10 +69,7 @@ def get_asset_nodes_by_asset_key(graphene_info) -> Mapping[AssetKey, "GrapheneAs
         for repository in location.get_repositories().values():
             for external_asset_node in repository.get_external_asset_nodes():
                 preexisting_node = asset_nodes_by_asset_key.get(external_asset_node.asset_key)
-                if (
-                    preexisting_node is None
-                    or preexisting_node.get_external_asset_node().op_name is None
-                ):
+                if preexisting_node is None or preexisting_node.external_asset_node.op_name is None:
                     asset_nodes_by_asset_key[external_asset_node.asset_key] = GrapheneAssetNode(
                         location, repository, external_asset_node
                     )