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..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: str, dialect) -> Optional[str]: + def process_result_value(self, value: Optional[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()