Skip to content

Commit

Permalink
fix(data-warehouse): Dont need to error on binary types anymore (Post…
Browse files Browse the repository at this point in the history
  • Loading branch information
Gilbert09 authored Feb 21, 2025
1 parent 5ced32e commit 14a93cf
Showing 1 changed file with 3 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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):
Expand All @@ -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

Expand Down

0 comments on commit 14a93cf

Please sign in to comment.