Skip to content
This repository was archived by the owner on Nov 12, 2025. It is now read-only.

Commit 0b796f9

Browse files
authored
bug: add exception case to support fastavro 1.8.4 (#687)
1 parent cbde9a6 commit 0b796f9

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

google/cloud/bigquery_storage_v1/reader.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -712,7 +712,7 @@ def to_rows(self, message):
712712
# TODO: Parse DATETIME into datetime.datetime (no timezone),
713713
# instead of as a string.
714714
yield fastavro.schemaless_reader(messageio, self._fastavro_schema)
715-
except StopIteration:
715+
except (StopIteration, EOFError):
716716
break # Finished with message
717717

718718

0 commit comments

Comments
 (0)