We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent f7f686c commit f25d7bdCopy full SHA for f25d7bd
bigframes/session/read_api_execution.py
@@ -80,16 +80,12 @@ def execute(
80
read_session=requested_session,
81
max_stream_count=1,
82
)
83
- session = self.bqstoragereadclient.create_read_session(
84
- request=request, retry=None
85
- )
+ session = self.bqstoragereadclient.create_read_session(request=request)
86
87
if not session.streams:
88
batches: Iterator[pa.RecordBatch] = iter([])
89
else:
90
- reader = self.bqstoragereadclient.read_rows(
91
- session.streams[0].name, retry=None
92
+ reader = self.bqstoragereadclient.read_rows(session.streams[0].name)
93
rowstream = reader.rows()
94
95
def process_page(page):
0 commit comments