From 7f0afc0718fba5aacccfdf8b72024a5baa3bbe11 Mon Sep 17 00:00:00 2001
From: Pablo Pardo Garcia <pablo@glassflow.dev>
Date: Fri, 6 Feb 2026 09:34:31 +0100
Subject: [PATCH 1/2] add support to map

---
 src/glassflow/etl/models/data_types.py | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git a/src/glassflow/etl/models/data_types.py b/src/glassflow/etl/models/data_types.py
index 981c049..aafbbcb 100644
--- a/src/glassflow/etl/models/data_types.py
+++ b/src/glassflow/etl/models/data_types.py
@@ -19,6 +19,7 @@ class KafkaDataType(CaseInsensitiveStrEnum):
     BOOL = "bool"
     BYTES = "bytes"
     ARRAY = "array"
+    MAP = "map"
 
 
 class ClickhouseDataType(CaseInsensitiveStrEnum):
@@ -78,6 +79,8 @@ class ClickhouseDataType(CaseInsensitiveStrEnum):
     ARRAY_LC_FLOAT64 = "Array(LowCardinality(Float64))"
     ARRAY_LC_DATETIME = "Array(LowCardinality(DateTime))"
     ARRAY_LC_FIXEDSTRING = "Array(LowCardinality(FixedString))"
+    ARRAY_MAP_STRING_STRING = "Array(Map(String, String))"
+    MAP_STRING_STRING = "Map(String, String)"
 
 
 kafka_to_clickhouse_data_type_mappings = {
@@ -92,6 +95,8 @@ class ClickhouseDataType(CaseInsensitiveStrEnum):
         ClickhouseDataType.LC_STRING,
         ClickhouseDataType.LC_FIXEDSTRING,
         ClickhouseDataType.LC_DATETIME,
+        ClickhouseDataType.MAP_STRING_STRING,
+        ClickhouseDataType.ARRAY_MAP_STRING_STRING,
     ],
     KafkaDataType.INT: [
         ClickhouseDataType.INT8,
@@ -158,5 +163,10 @@ class ClickhouseDataType(CaseInsensitiveStrEnum):
         ClickhouseDataType.ARRAY_LC_FLOAT64,
         ClickhouseDataType.ARRAY_LC_DATETIME,
         ClickhouseDataType.ARRAY_LC_FIXEDSTRING,
+        ClickhouseDataType.ARRAY_MAP_STRING_STRING,
+    ],
+    KafkaDataType.MAP: [
+        ClickhouseDataType.MAP_STRING_STRING,
+        ClickhouseDataType.ARRAY_MAP_STRING_STRING,
     ],
 }

From 528439e77fd88b79c2d52289f2f78dc6aed4eeaa Mon Sep 17 00:00:00 2001
From: "github-actions[bot]" <github-actions[bot]@users.noreply.github.com>
Date: Fri, 6 Feb 2026 08:35:51 +0000
Subject: [PATCH 2/2] chore: bump version to 3.7.2

---
 VERSION | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/VERSION b/VERSION
index a76ccff..0b2eb36 100644
--- a/VERSION
+++ b/VERSION
@@ -1 +1 @@
-3.7.1
+3.7.2