File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed
packages/google-cloud-storage/google/cloud/storage/asyncio Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -469,7 +469,7 @@ async def generator():
469469 broken_gen , stream_factory
470470 )
471471
472- my_generation = self ._multiplexer .stream_generation
472+ stream_generation = self ._multiplexer .stream_generation
473473
474474 # Send Requests
475475 pending_read_ids = {r .read_id for r in requests }
@@ -482,7 +482,7 @@ async def generator():
482482 _storage_v2 .BidiReadObjectRequest (read_ranges = batch )
483483 )
484484 except Exception :
485- last_broken_generation = my_generation
485+ last_broken_generation = stream_generation
486486 raise
487487
488488 # Receive Responses
@@ -491,14 +491,14 @@ async def generator():
491491
492492 if isinstance (item , _StreamEnd ):
493493 if pending_read_ids :
494- last_broken_generation = my_generation
494+ last_broken_generation = stream_generation
495495 raise exceptions .ServiceUnavailable (
496496 "Stream ended with pending read_ids"
497497 )
498498 break
499499
500500 if isinstance (item , _StreamError ):
501- if item .generation < my_generation :
501+ if item .generation < stream_generation :
502502 continue # stale error, skip
503503 last_broken_generation = item .generation
504504 raise item .exception
You can’t perform that action at this time.
0 commit comments