1SrSSKJr SSKJr SSKJr SSKJr SSKJr SSKJ r SSKJ r "S S \R5r g ) z*Download workflow used by GCS gRPC client.)absolute_import)division)unicode_literals) cloud_api) gcs_download) grpc_util) retry_utilch^\rSrSrSrU4SjrSrSr\RS5r U4Sjr Sr U=r $) GrpcDownloadz$Perform GCS Download using gRPC API.c n>[T U]X4U5 XlX lX`lXplXlXlg)aInitializes a GrpcDownload instance. Args: gapic_client (StorageClient): The GAPIC API client to interact with GCS using gRPC. cloud_resource (resource_reference.ObjectResource): See cloud_api.CloudApi.download_object. download_stream (stream): Stream to send the object data to. start_byte (int): See super class. end_byte (int): See super class. digesters (dict): See cloud_api.CloudApi.download_object. progress_callback (function): See cloud_api.CloudApi.download_object. download_strategy (cloud_api.DownloadStrategy): Download strategy used to perform the download. decryption_key (encryption_util.EncryptionKey|None): The decryption key to be used to download the object if the object is encrypted. N)super__init__ _gapic_client_cloud_resource _digesters_progress_callback_download_strategy_decryption_key) self gapic_clientcloud_resourcedownload_stream start_byteend_byte digestersprogress_callbackdownload_strategydecryption_key __class__s 7lib/googlecloudsdk/api_lib/storage/gcs_grpc/download.pyrGrpcDownload.__init__s96 )T#OJ%)O//)c0[R"XU5$)See super class.)r is_retriable)rexc_type exc_value exc_tracebacks r! should_retryGrpcDownload.should_retryAs  " "8 FFr#c [R"URURURUR UR URURURURS9 $)r%) rrrrrrrrr) rdownload_objectrr_download_streamrr _start_byte _end_byterrrs r!launchGrpcDownload.launchEsb  $ $''++--//11##11++  r#c"UR5$)a_Downloads the object. On retriable errors, the entire download will be re-performed instead of resuming from a particular byte. This is useful for streaming download cases. Unlike Apitools, the GAPIC client doesn't retry the request by default, hence we are using the decorator. Returns: Encoding string for object if requested. Otherwise, None. )r2r1s r!simple_downloadGrpcDownload.simple_downloadSs ;;=r#c>UR[RR:XaUR 5$[ TU]SS9$)r%T)retriable_in_flight)rrDownloadStrategyONE_SHOTr5rrun)rr s r!r;GrpcDownload.runcsA )"<"<"E"EE  ! ! ## 9d 'D ' AAr#)rrrrrr)__name__ __module__ __qualname____firstlineno____doc__rr*r2r grpc_default_retryerr5r;__static_attributes__ __classcell__)r s@r!r r s=,!*FG "" # BBr#r N) rA __future__rrrgooglecloudsdk.api_lib.storagerr'googlecloudsdk.api_lib.storage.gcs_grpcrr GcsDownloadr r#r!rJs51&'47=>MB<++MBr#