fix: new type

ralphrass · ralphrass · commit 3c78e31bb9b0 · 2024-06-28T15:51:55.000-03:00
diff --git a/butterfree/configs/db/cassandra_config.py b/butterfree/configs/db/cassandra_config.py
@@ -229,6 +229,7 @@ def translate(self, schema: List[Dict[str, Any]]) -> List[Dict[str, Any]]:
         """
         cassandra_mapping = {
             "timestamptype": "timestamp",
+            "timestampntztype": "timestamp",
             "binarytype": "boolean",
             "booleantype": "boolean",
             "datetype": "timestamp",
