fixed read_rows

daniel-sanche · daniel-sanche · commit 55ff4d1c148c · 2025-09-15T14:49:32.000-07:00
diff --git a/google/cloud/bigtable/data/_async/_read_rows.py b/google/cloud/bigtable/data/_async/_read_rows.py
@@ -213,7 +213,6 @@ async def chunk_stream(
                             raise InvalidChunk("emit count exceeds row limit")
                     current_key = None
 
-    @staticmethod
     @CrossSync.convert(
         replace_symbols={"__aiter__": "__iter__", "__anext__": "__next__"},
     )
diff --git a/google/cloud/bigtable/data/_sync_autogen/_read_rows.py b/google/cloud/bigtable/data/_sync_autogen/_read_rows.py
@@ -180,7 +180,6 @@ def chunk_stream(
                             raise InvalidChunk("emit count exceeds row limit")
                     current_key = None
 
-    @staticmethod
     def merge_rows(
         self, chunks: CrossSync._Sync_Impl.Iterable[ReadRowsResponsePB.CellChunk] | None
     ) -> CrossSync._Sync_Impl.Iterable[Row]:

Original file line number	Diff line number	Diff line change
`@@ -213,7 +213,6 @@ async def chunk_stream(`
`213`	`213`	`raise InvalidChunk("emit count exceeds row limit")`
`214`	`214`	`current_key = None`
`215`	`215`
`216`		`- @staticmethod`
`217`	`216`	`@CrossSync.convert(`
`218`	`217`	`replace_symbols={"__aiter__": "__iter__", "__anext__": "__next__"},`
`219`	`218`	`)`