From 14a93cf4ea7b421046dafe44af4964712a538897 Mon Sep 17 00:00:00 2001 From: Tom Owers Date: Fri, 21 Feb 2025 15:49:03 +0100 Subject: [PATCH] fix(data-warehouse): Dont need to error on binary types anymore (#29052) --- .../temporal/data_imports/pipelines/pipeline/hogql_schema.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/posthog/temporal/data_imports/pipelines/pipeline/hogql_schema.py b/posthog/temporal/data_imports/pipelines/pipeline/hogql_schema.py index 383a3296f0435..5a0ba46dff493 100644 --- a/posthog/temporal/data_imports/pipelines/pipeline/hogql_schema.py +++ b/posthog/temporal/data_imports/pipelines/pipeline/hogql_schema.py @@ -27,6 +27,9 @@ def add_field(self, field: pa.Field, column: pa.ChunkedArray) -> None: if existing_type is not None and existing_type != StringDatabaseField.__name__: return + if pa.types.is_binary(field.type): + return + hogql_type: type[DatabaseField] = DatabaseField if pa.types.is_time(field.type): @@ -43,8 +46,6 @@ def add_field(self, field: pa.Field, column: pa.ChunkedArray) -> None: hogql_type = BooleanDatabaseField elif pa.types.is_integer(field.type): hogql_type = IntegerDatabaseField - elif pa.types.is_binary(field.type): - raise Exception("Type 'binary' is not a supported column type") elif pa.types.is_string(field.type): hogql_type = StringDatabaseField