From 71059771fda5c4d66c3d4df06239b616cee4c7fa Mon Sep 17 00:00:00 2001 From: sushi30 Date: Mon, 22 Jul 2024 11:01:35 +0200 Subject: [PATCH 1/3] changed log level to debug --- .../src/metadata/profiler/orm/types/custom_hex_byte_string.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/ingestion/src/metadata/profiler/orm/types/custom_hex_byte_string.py b/ingestion/src/metadata/profiler/orm/types/custom_hex_byte_string.py index 1e27adb3ce33..2464e4ee6761 100644 --- a/ingestion/src/metadata/profiler/orm/types/custom_hex_byte_string.py +++ b/ingestion/src/metadata/profiler/orm/types/custom_hex_byte_string.py @@ -46,7 +46,7 @@ def validate(value: bytes): f"HexByteString columns support only bytes values. Received {type(value).__name__}." ) - def process_result_value(self, value: str, dialect) -> Optional[str]: + def process_result_value(self, value: bytes, dialect) -> Optional[str]: """This is executed during result retrieval Args: @@ -66,8 +66,8 @@ def process_result_value(self, value: str, dialect) -> Optional[str]: value = bytes_value.decode(encoding=detected_encoding) return value except Exception as exc: + logger.debug("Failed to parse bytes valud as string: %s", exc) logger.debug(traceback.format_exc()) - logger.error(exc) return value.hex() From 1d746d358fb10c6244d7196730b4dd993e999acf Mon Sep 17 00:00:00 2001 From: sushi30 Date: Mon, 22 Jul 2024 11:02:16 +0200 Subject: [PATCH 2/3] fixed type --- .../src/metadata/profiler/orm/types/custom_hex_byte_string.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/ingestion/src/metadata/profiler/orm/types/custom_hex_byte_string.py b/ingestion/src/metadata/profiler/orm/types/custom_hex_byte_string.py index 2464e4ee6761..5d867372253d 100644 --- a/ingestion/src/metadata/profiler/orm/types/custom_hex_byte_string.py +++ b/ingestion/src/metadata/profiler/orm/types/custom_hex_byte_string.py @@ -46,7 +46,7 @@ def validate(value: bytes): f"HexByteString columns support only bytes values. Received {type(value).__name__}." ) - def process_result_value(self, value: bytes, dialect) -> Optional[str]: + def process_result_value(self, value: Optiona[bytes], dialect) -> Optional[str]: """This is executed during result retrieval Args: From d44a67ff3e1682bc021b462dfcb7cf974f68d31a Mon Sep 17 00:00:00 2001 From: sushi30 Date: Mon, 22 Jul 2024 11:02:32 +0200 Subject: [PATCH 3/3] changed type to optional --- .../src/metadata/profiler/orm/types/custom_hex_byte_string.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/ingestion/src/metadata/profiler/orm/types/custom_hex_byte_string.py b/ingestion/src/metadata/profiler/orm/types/custom_hex_byte_string.py index 5d867372253d..e87afd234e88 100644 --- a/ingestion/src/metadata/profiler/orm/types/custom_hex_byte_string.py +++ b/ingestion/src/metadata/profiler/orm/types/custom_hex_byte_string.py @@ -46,7 +46,7 @@ def validate(value: bytes): f"HexByteString columns support only bytes values. Received {type(value).__name__}." ) - def process_result_value(self, value: Optiona[bytes], dialect) -> Optional[str]: + def process_result_value(self, value: Optional[bytes], dialect) -> Optional[str]: """This is executed during result retrieval Args: