Skip to content

Commit df041cf

Browse files
rambleraptorFokko
andauthored
Update pyiceberg/io/pyarrow.py
Co-authored-by: Fokko Driesprong <fokko@apache.org>
1 parent 4bbd92d commit df041cf

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

pyiceberg/io/pyarrow.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1306,7 +1306,7 @@ def primitive(self, primitive: pa.DataType) -> PrimitiveType:
13061306
elif primitive.unit == "ns":
13071307
if self._downcast_ns_timestamp_to_us:
13081308
logger.warning("Iceberg does not yet support 'ns' timestamp precision. Downcasting to 'us'.")
1309-
elif self._format_version == 3:
1309+
elif self._format_version >= 3:
13101310
if primitive.tz in UTC_ALIASES:
13111311
return TimestamptzNanoType()
13121312
else:

0 commit comments

Comments
 (0)