From bb7dbb04b86c1c259b1314a8112f61c3e8826685 Mon Sep 17 00:00:00 2001 From: Ayush Shah Date: Tue, 29 Mar 2022 01:31:35 -0700 Subject: [PATCH] Fix for unhashable type (#3729) --- .../src/metadata/ingestion/bulksink/metadata_usage.py | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/ingestion/src/metadata/ingestion/bulksink/metadata_usage.py b/ingestion/src/metadata/ingestion/bulksink/metadata_usage.py index 5944accd006..00fab288ab2 100644 --- a/ingestion/src/metadata/ingestion/bulksink/metadata_usage.py +++ b/ingestion/src/metadata/ingestion/bulksink/metadata_usage.py @@ -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(