[ `dZddlmZddlmZddlmZddlZddlmZddlmZ ddl mZ ddl m Z dd l m Z dd lmZdd lmZdd lmZdd lmZddlmZddlmZddddZGddej0ZGddeZGddZGddeeZGddeeZdZdZd Z d!Z!y)"zGeneral utilities for copies.)absolute_import)division)unicode_literalsN) cloud_api)errors) manifest_util) storage_url)resource_reference) resource_util)task) exceptions)log) propertiesZim)nearlinecoldlinearchivec2eZdZdZ dfd ZdZxZS)CopyTaskzHParent task that handles common attributes and an __init__ status print.ctt| ||_||_||_||_||_||_t|jxr|jj|_ |r}|j r|jj}n|jj}tj j#dj%||jjyy)ayInitializes 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  cz|jr/tjjdj |yy)Nz Created: {})rrr%r&r')r(resources r1#_print_created_message_if_requestedz,CopyTask._print_created_message_if_requested\s- "" jj}++H56#r2)FFNF)__name__ __module__ __qualname____doc__rr5 __classcell__r0s@r1rr*sP " -^7r2rc.eZdZdZ dfd ZxZS)ObjectCopyTaskzAParent task that handles common attributes for object copy tasks.cR||_||_tt|||||||y)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_setrrr=r) r(r)r* posix_to_setr+r,r-r.r0s r1rzObjectCopyTask.__init__ds8,&D"6D .$( r2)NFFNF)r6r7r8r9rr:r;s@r1r=r=as!I ! ""r2r=ceZdZdZddZy)_ExitHandlerMixinz(Provides an exit handler for copy tasks.Nc|rj|jr]|s.tjdj|jt j ||j|j|yyy)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 r1 exit_handlerz_ExitHandlerMixin.exit_handlersh -- "" ? F F%%   &&'8$:O:O'+'A'A5J.ur2)NN)r6r7r8r9rIr2r1rBrBs 0 Jr2rBceZdZdZy)CopyTaskWithExitHandlerz;Parent task with an exit handler for non-object copy tasks.Nr6r7r8r9rJr2r1rLrLs Dr2rLceZdZdZy)ObjectCopyTaskWithExitHandlerz7Parent task with an exit handler for object copy tasks.NrMrJr2r1rOrOs?r2rOc$dj|S)z(Returns standardized no clobber warning.z3Skipping existing destination item (no-clobber): {})r')destination_urls r1get_no_clobber_messagerRs > E E r2c|r |jsy |j|jj|jjt j jy#tj$rYywxYw)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 r1check_for_cloud_clobberr^sw  1 < < ""((44((66**00#2   ! ! sAA&&A<;A<cN|j |jS|jryy)z=Prioritizes user-input generation over no-clobber zero value.Nr)precondition_generation_matchrU)request_configs r1get_generation_match_valuerbs)11=  7 77 r2ct|tjrytjj j jrN|jjtjjur|jr|jtvsyt|jj}t!j"|j}t!j"t$j$j'}||t%j(|zkr;t+j,dj/||j|j|y)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 rEr')object_resourceminimum_lifetimecreation_datetime_utccurrent_datetime_utcs r1&raise_if_mv_early_deletion_fee_appliesrzs.!3!B!BC    # # ? ? G G I  % % , , 0J0J0N0N N++  ' '+G G 1##))+-'FF##%&EE1H4F4F 5    J &/"?"? ..0@ B  CCr2)"r9 __future__rrrrsgooglecloudsdk.api_lib.storagerrr["googlecloudsdk.command_lib.storagerDrr ,googlecloudsdk.command_lib.storage.resourcesr r (googlecloudsdk.command_lib.storage.tasksr googlecloudsdk.corer rrrpTaskrr=rBrLrOrRr^rbrzrJr2r1rs$&'4?G<:KF9*#* 47tyy47n%X%P J J D D@$5~@ Cr2