[ `SrSSKJr SSKJr SSKJr SSKrSSKJr SSKJr SSK Jr SSK J r SS K J r SS KJr SS KJr SS KJr SS KJr SSKJr SSKJr SSSS.r"SS\R05r"SS\5r"SS5r"SS\\5r"SS\\5rSrSrS r S!r!g)"zGeneral utilities for copies.)absolute_import)division)unicode_literalsN) cloud_api)errors) manifest_util) storage_url)resource_reference) resource_util)task) exceptions)log) propertiesZim)nearlinecoldlinearchivec>^\rSrSrSrSU4SjjrSrSrU=r$)CopyTask*zHParent task that handles common attributes and an __init__ status print.c>[[U] 5 XlX lX0lX@lXPlX`l[UR=(a URR5Ul U(aUR (aURRnOURRn[R R#SR%UURR55 gg)aIInitializes task. Args: source_resource (resource_reference.Resource): Source resource to copy. destination_resource (resource_reference.Resource): Target resource to copy to. print_created_message (bool): Print a message containing the URL of the copy result. print_source_version (bool): Print source object version in status message enabled by the `verbose` kwarg. user_request_args (UserRequestArgs|None): Various user-set values typically converted to an API-specific RequestConfig. verbose (bool): Print a "copying" status message on initialization. zCopying {} to {}N)superr__init___source_resource_destination_resource_print_created_message_print_source_version_user_request_args_verbosebool manifest_path_send_manifest_messagesr url_stringversionless_url_stringrstatusPrintformat) selfsource_resourcedestination_resourceprint_created_messageprint_source_versionuser_request_argsverbose source_string __class__s > '33JJ  jj  # #"..EE  cUR(a/[RRSR U55 gg)Nz Created: {})rrr&r'r()r)resources r2#_print_created_message_if_requested,CopyTask._print_created_message_if_requested\s- "" jj}++H56#r4)rrrr#rrr )FFNF) __name__ __module__ __qualname____firstlineno____doc__rr7__static_attributes__ __classcell__r1s@r2rr*s$P " -^77r4rc:^\rSrSrSrSU4SjjrSrU=r$)ObjectCopyTaskazAParent task that handles common attributes for object copy tasks.cN>X0lXPl[[U]UUUUUU5 g)aInitializes task. Args: source_resource (resource_reference.Resource): See parent class. destination_resource (resource_reference.Resource): See parent class. posix_to_set (PosixAttributes|None): POSIX info set as custom cloud metadata on target. print_created_message (bool): See parent class. print_source_version (bool): See parent class. user_request_args (UserRequestArgs|None): See parent class. verbose (bool): Print a "copying" status message on initialization. N) _posix_to_setrrrBr) r)r*r+ posix_to_setr,r-r.r/r1s r2rObjectCopyTask.__init__ds4,&"6 .$( r4)rEr)NFFNF)r9r:r;r<r=rr>r?r@s@r2rBrBas!I ! ""r4rBc"\rSrSrSrSSjrSrg)_ExitHandlerMixinz(Provides an exit handler for copy tasks.NcU(auUR(acU(d/[R"SRUR55e[ R "X RURU5 ggg)z/Send copy result info to manifest if requested.z1Unable to send message to manifest for source: {}N)r#command_errorsErrorr(rrsend_error_messager)r)errortask_status_queues r2 exit_handler_ExitHandlerMixin.exit_handlersf -- "" ? F F%%   &&'8:O:O'+'A'A5J.ur4)NN)r9r:r;r<r=rQr>rSr4r2rIrIs 0 Jr4rIc\rSrSrSrSrg)CopyTaskWithExitHandlerz;Parent task with an exit handler for non-object copy tasks.rSNr9r:r;r<r=r>rSr4r2rUrUs Dr4rUc\rSrSrSrSrg)ObjectCopyTaskWithExitHandlerz7Parent task with an exit handler for object copy tasks.rSNrWrSr4r2rYrYs?r4rYc$SRU5$)z(Returns standardized no clobber warning.z3Skipping existing destination item (no-clobber): {})r()destination_urls r2get_no_clobber_messager]s > E E r4cU(aUR(dgURURRURR[ R RS9 g![Ra gf=f)zAReturns if cloud destination object exists if no-clobber enabled.F) fields_scopeT) no_clobberget_object_metadatar bucket_name resource_namer FieldsScopeSHORT api_errors NotFoundError)r. api_clientr+s r2check_for_cloud_clobberrisw  1 < < ""((44((66**00#2   ! ! sAA--BBcZURb UR$UR(agg)z=Prioritizes user-input generation over no-clobber zero value.Nr)precondition_generation_matchr`)request_configs r2get_generation_match_valuerms)11=  7 77 r4c[U[R5(ag[RR R R5(aVURR[RRLa%UR(aUR[;dg[URR5n[ R""UR5n[ R""[$R$R'55nX2[$R("US9-:a;[*R,"SR/XRURU55eg)zGRaises error if Google Cloud Storage object will incur an extra charge.N)daysaFDeleting {} may incur an early deletion charge. Note: the source object of a mv operation is deleted. The object appears to have been created on {}, and the minimum time before deletion for the {} storage class is {} days. To allow deleting the object anyways, run "gcloud config set storage/check_mv_early_deletion_fee False") isinstancer FolderResourcerVALUESstoragecheck_mv_early_deletion_feeGetBoolr schemeProviderPrefixGCS creation_time storage_class_EARLY_DELETION_MINIMUM_DAYSlowerr convert_datetime_object_to_utcdatetimenow timedeltar rMr()object_resourceminimum_lifetimecreation_datetime_utccurrent_datetime_utcs r2&raise_if_mv_early_deletion_fee_appliesrs/!3!B!BCC    # # ? ? G G I I  % % , , 0J0J0N0N N++  ' '+G G 1##))+-'FF##%&EEH4F4F 5    J &"?"? ..0@ B  CCr4)"r= __future__rrrr~googlecloudsdk.api_lib.storagerrrf"googlecloudsdk.command_lib.storagerLrr ,googlecloudsdk.command_lib.storage.resourcesr r (googlecloudsdk.command_lib.storage.tasksr googlecloudsdk.corer rrr{TaskrrBrIrUrYr]rirmrrSr4r2rs$&'4?G<:KF9*#* 47tyy47n%X%P J J D D@$5~@ Cr4