Skip to content

Commit

Permalink
Merge pull request amundsen-io#53 from data-foundations/feature/metadata
Browse files Browse the repository at this point in the history
Merge pull request amundsen-io#52 from data-foundations/feature/metadata-fixes
  • Loading branch information
Judy Palimonka authored and GitHub Enterprise committed Nov 11, 2021
2 parents 94e509b + d4c9578 commit 5d2423b
Show file tree
Hide file tree
Showing 2 changed files with 1 addition and 4 deletions.
3 changes: 0 additions & 3 deletions metadata/metadata_service/proxy/neo4j_proxy.py
Original file line number Diff line number Diff line change
Expand Up @@ -1838,7 +1838,6 @@ def get_lineage(self, *,
get_upstream_lineage_query = textwrap.dedent(u"""
MATCH (source:{resource} {{key: $query_key}})
OPTIONAL MATCH path=(source)-[upstream_len:HAS_UPSTREAM*..{depth}]->(upstream_entity:{resource})
ORDER BY upstream_entity.key
WITH upstream_entity, upstream_len, path
OPTIONAL MATCH (upstream_entity)-[:HAS_BADGE]->(upstream_badge:Badge)
WITH CASE WHEN upstream_badge IS NULL THEN []
Expand All @@ -1847,7 +1846,6 @@ def get_lineage(self, *,
OPTIONAL MATCH (upstream_entity:{resource})-[upstream_read:READ_BY]->(:User)
WITH upstream_entity, upstream_len, upstream_badges,
sum(upstream_read.read_count) as upstream_read_count, path
ORDER BY upstream_entity.key
WITH CASE WHEN upstream_len IS NULL THEN []
ELSE COLLECT(distinct{{level:SIZE(upstream_len), source:split(upstream_entity.key,'://')[0],
key:upstream_entity.key, badges:upstream_badges, usage:upstream_read_count, parent:nodes(path)[-2].key}})
Expand All @@ -1865,7 +1863,6 @@ def get_lineage(self, *,
OPTIONAL MATCH (downstream_entity:{resource})-[downstream_read:READ_BY]->(:User)
WITH downstream_entity, downstream_len, downstream_badges,
sum(downstream_read.read_count) as downstream_read_count, path
ORDER BY downstream_entity.key
WITH CASE WHEN downstream_len IS NULL THEN []
ELSE COLLECT(distinct{{level:SIZE(downstream_len), source:split(downstream_entity.key,'://')[0],
key:downstream_entity.key, badges:downstream_badges, usage:downstream_read_count, parent:nodes(path)[-2].key}})
Expand Down
2 changes: 1 addition & 1 deletion metadata/setup.py
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
from setuptools import find_packages, setup


__version__ = '3.9.0+king7'
__version__ = '3.9.0+king8'

requirements_path = os.path.join(os.path.dirname(os.path.realpath(__file__)), 'requirements.txt')
with open(requirements_path) as requirements_file:
Expand Down

0 comments on commit 5d2423b

Please sign in to comment.