Skip to content

Commit be24d12

Browse files
committed
Fix bug with is vs in check
1 parent 7a9be0e commit be24d12

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

  • elt-common/src/elt_common/dlt_destinations/pyiceberg

elt-common/src/elt_common/dlt_destinations/pyiceberg/pyiceberg.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -342,7 +342,7 @@ def get_storage_tables(
342342
for field in schema.fields:
343343
column = self.type_mapper.from_destination_type(field)
344344
column["name"] = field.name
345-
if field.field_id is schema.identifier_field_ids:
345+
if field.field_id in schema.identifier_field_ids:
346346
column["primary_key"] = True
347347
storage_columns[field.name] = column
348348

0 commit comments

Comments
 (0)