yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-08-06 08:08:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix for unhashable type (#3729)

Browse Source
This commit is contained in:
Ayush Shah 2022-03-29 01:31:35 -07:00 committed by GitHub
parent e830f1787f
commit bb7dbb04b8
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
ingestion/src/metadata/ingestion/bulksink/metadata_usage.py
View File

@ -177,13 +177,13 @@ class MetadataUsageBulkSink(BulkSink):
joined_column_fqdn = self.__get_column_fqdn(
table_usage.database, column
)
if joined_column_fqdn in joined_with.keys():
column_joined_with = joined_with[joined_column_fqdn]
if str(joined_column_fqdn) in joined_with.keys():
column_joined_with = joined_with[str(joined_column_fqdn)]
column_joined_with.joinCount += 1
joined_with[joined_column_fqdn] = column_joined_with
joined_with[str(joined_column_fqdn)] = column_joined_with
elif joined_column_fqdn is not None:
joined_with[joined_column_fqdn] = ColumnJoinedWith(
fullyQualifiedName=joined_column_fqdn, joinCount=1
joined_with[str(joined_column_fqdn)] = ColumnJoinedWith(
fullyQualifiedName=str(joined_column_fqdn), joinCount=1
)
else:
logger.info(