@@ -233,7 +233,6 @@ def __init__(
233233 self ._open_retries : int = 0
234234 self .is_finalized : bool = False
235235 self .full_obj_server_crc32c : Optional [int ] = None
236- self .object_metadata : Optional [_storage_v2 .Object ] = None
237236
238237 async def __aenter__ (self ):
239238 """Opens the underlying bidi-gRPC connection to read from the object."""
@@ -331,7 +330,6 @@ async def _do_open():
331330 self .persisted_size = self .read_obj_str .persisted_size
332331 self .is_finalized = self .read_obj_str .is_finalized
333332 self .full_obj_server_crc32c = self .read_obj_str .full_obj_server_crc32c
334- self .object_metadata = self .read_obj_str .object_metadata
335333
336334 self ._is_stream_open = True
337335
@@ -370,7 +368,6 @@ async def factory():
370368 self .read_handle = stream .read_handle
371369 self .is_finalized = stream .is_finalized
372370 self .full_obj_server_crc32c = stream .full_obj_server_crc32c
373- self .object_metadata = stream .object_metadata
374371
375372 self .read_obj_str = stream
376373 self ._is_stream_open = True
@@ -580,3 +577,9 @@ async def close(self):
580577 @property
581578 def is_stream_open (self ) -> bool :
582579 return self ._is_stream_open
580+
581+ @property
582+ def object_metadata (self ) -> Optional [_storage_v2 .Object ]:
583+ """The metadata of the object being downloaded."""
584+ stream = getattr (self , "read_obj_str" , None )
585+ return stream .object_metadata if stream else None
0 commit comments