From 0ac23600d9bf0222333319cee04fdbb06abdcae1 Mon Sep 17 00:00:00 2001 From: Benjamin Theunissen Date: Tue, 21 Nov 2023 16:38:06 -0500 Subject: [PATCH] Fix --- target_clickhouse/sinks.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/target_clickhouse/sinks.py b/target_clickhouse/sinks.py index f3e30dd..b3f9c3a 100644 --- a/target_clickhouse/sinks.py +++ b/target_clickhouse/sinks.py @@ -175,6 +175,8 @@ def _pre_validate_for_string_type(self, record: dict) -> dict: for key, value in record.items(): # Checking if the schema expects a string for this key. expected_type = self.schema.get("properties", {}).get(key, {}).get("type") + if expected_type is None: + continue if "string" in expected_type and not isinstance(value, str): # Convert the value to string if it's not already a string. record[key] = (