1SrSSKJr SSKJr SSKJr SSKrSSKJr SSKJ r SSK J r SS K J r SS KJr SS KJr SS KJr SS KJr SSKJr SSKJr SSKrSSKJr S\ R2\ R4\ R4\ R6S\ R8S.rS)SjrSrSr Sr!Sr"Sr#Sr$Sr%Sr&Sr'Sr(Sr)S r*S!r+\ RXRZ4S"jr.S#r/S$r0S%r1S&r2S'r3S(r4g)*zUtilities for `gcloud app deploy .yaml` deployments. Functions defined here are used to migrate away from soon to be deprecated admin-console-hr superapp. Instead we will be using Cloud Tasks APIs. )absolute_import)division)unicode_literalsN)util)task_queues_convertors)base)parser_extensions)app) constants)flags)parsers) exceptions) properties)urllibc @[S[S[U555$)Ni)minmaxintxs =lib/googlecloudsdk/api_lib/tasks/app_deploy_migration_util.pyr.sT3q#a&>)Bc[U5S-$)Nr)rrs rrr3s 3q6A:r)max_concurrent_requestsratez$retry_parameters.min_backoff_secondsz$retry_parameters.max_backoff_secondszretry_parameters.task_age_limitz!retry_parameters.task_retry_limittargetc t[X- 5[U[[U5[U55-U5:*$)aChecks if two numerical values are same or almost the same. This function is only created to provides backwards compatability for python2 which does not support 'math.isclose(...)' function. The output of this function mimicks exactly the behavior of math.isclose. Args: a: One of the values to be tested for relative closeness. b: One of the values to be tested for relative closeness. rel_tol: Relative tolerance allowed. Default value is set so that the two values must be equivalent to 9 decimal digits. abs_tol: The minimum absoulute tolerance difference. Useful for comparisons near zero. Returns: True if the attribute needs to be updated to the new value, False otherwise. )absr)abrel_tolabs_tols rIsCloser%8s0$ QSS3s1vs1v#66@ @@rc[R"U5n[US5(a2[URU5(a[ URU5nO3[UR U5(a[ UR U5nOgXB:XagUc2US:wa,U[ R;aU[ RU:XagUS:XaU(dgUbUcg[R"U5n[R"U5n[U[5(a%[U[5(a[XB5(+$XB:g$)aChecks whether the attribute & value provided need to be updated. Note: We only check if the attribute exists in `queue.rateLimits` and `queue.retryConfig` since those are the only attributes we verify here. The only attribute we do not verify here is app-engine routing override which we handle separately. Args: cur_queue_state: apis.cloudtasks..cloudtasks__messages.Queue, The Queue instance fetched from the backend. attribute: Snake case representation of the CT API attribute name. One example is 'max_burst_size'. new_value: The value we are trying to set this attribute to. Returns: True if the attribute needs to be updated to the new value, False otherwise. rateLimitsTFmax_concurrent_dispatchesmax_dispatches_per_second) convertorsConvertStringToCamelCasehasattrr'getattr retryConfigr %PUSH_QUEUES_APP_DEPLOY_DEFAULT_VALUES(CheckAndConvertStringToFloatIfApplicable isinstancefloatr%)cur_queue_state attribute new_valueproto_attribute_name old_values r_DoesAttributeNeedToBeUpdatedr8Ms $$<??224HII**,@AA335IJI  ..9BBB9BB9MM --i )+ AA)L)AA)L)E""E""y, ,,  rc X RU'g)aSets the specified key, value pair in the namespace provided. The main reason to have this function is to centralize all the protected access to _specified_args Args: cloud_task_args: argparse.Namespace, A placeholder args namespace built to pass on forwards to Cloud Tasks API. key: The attribute key we are trying to set. value: The attribute value we are trying to set. N_specified_args)cloud_task_argskeyvalues r_SetSpecifiedArgr?s*/!!#&rcURU g)zDeletes the specified key in the namespace provided. Args: cloud_task_args: argparse.Namespace, A placeholder args namespace built to pass on forwards to Cloud Tasks API. key: The attribute key we are trying to set. Nr:)r<r=s r_DeleteSpecifiedArgrAs%%c*rcURS:Xag[R"UR5n[R"UR5nX4:a\U(a+UnURUl[ USUR5 O*UnURUl[ USUR5 U(aUR (a[R"UR R5n[R"UR R5nXF:Xa-X5:Xa'[US5 SUl[US5 SUlggggg)a!Checks min and max backoff values and updates the other value if needed. When uploading via queue.yaml files, if only one of the backoff values is specified, the other value will automatically be updated to the default value. If the default value does not satisfy the condition min_backoff <= max_backoff, then it is set equal to the other backoff value. Args: cloud_task_args: argparse.Namespace, A placeholder args namespace built to pass on forwards to Cloud Tasks API. used_default_value_for_min_backoff: A boolean value telling us if we used a default value for min_backoff or if it was specified explicitly in the YAML file. cur_queue_state: apis.cloudtasks..cloudtasks__messages.Queue, The Queue instance fetched from the backend if it exists, None otherwise. pullN min_backoff max_backoff) typer*r0rDrEr?r. minBackoff maxBackoffrA)r<"used_default_value_for_min_backoffr3rDrEold_min_backoffold_max_backoffs r_PostProcessMinMaxBackoffrLs.$V# CC!!#+CC!!#+)k$3$?$?o! =/*E*EG k$3$?$?o! =/*E*EG44 II##..0O II##..0O%+*H/=9$(o!/=9$(o! +I% 5_rcLURRRnUR S5(a/nSUR ;aUR UR S5 SUR ;aUR UR S5 SRU5nSRU[RRRR55nURU5(aURS SUlggg![a gf=f)a;Checks if service and target values need to be updated for host URL. An app engine host URL may have optionally version_dot_service appended to the URL if specified via 'routing_override'. Here we check the existing URL and make sure the service & target values are only updated when need be. Args: cloud_task_args: argparse.Namespace, A placeholder args namespace built to pass on forwards to Cloud Tasks API. cur_queue_state: apis.cloudtasks..cloudtasks__messages.Queue, The Queue instance fetched from the backend if it exists, None otherwise. Nrouting_overrideversionservice.z{}.{}.)appEngineHttpQueueappEngineRoutingOverridehostAttributeError IsSpecifiedrNappendjoinformatrVALUEScoreprojectGet startswithr;)r<r3host_urltargetstargets_sub_urltargets_sub_url_and_projects r_PostProcessRoutingOverridercs 11JJOOH  !344GO444 nn_55i@AO444 nn_55i@Ahhw'O"*//**//77;;=#?677  ) )*< =)-o&85    s D D#"D#c[R"5nUHn[X4S5 M Sn[RR 5GHupgUR S5nUn UH"n [X5(dSn O[X5n M$ U (d U bJUS;aDU[;a[U"U 5n U(aUS;d[XU 5(a [X7U 5 OzUR[R:Xa[Rn O[Rn X{;a6US:XaSnXn U(aUS;d[XU 5(a [X7U 5 [X7U 5 GM [!X5U5 [#X15 U$) aBuilds placeholder command line args to pass on to Cloud Tasks API. Most of Cloud Tasks functions use args passed in during CLI invocation. To reuse those functions without extensive rework on their implementation, we recreate the args in the format that those functions expect. Args: queue: third_party.appengine.api.queueinfo.QueueEntry, The QueueEntry instance generated from the parsed YAML file. cur_queue_state: apis.cloudtasks..cloudtasks__messages.Queue, The Queue instance fetched from the backend if it exists, None otherwise. ct_expected_args: A list of expected args that we need to initialize before forwarding to Cloud Tasks APIs. Returns: argparse.Namespace, A placeholder args namespace built to pass on forwards to Cloud Tasks API. NFrQ) max_attempts)namerFrDrErDT)rDrE)r Namespacesetattrr APP_TO_TASKS_ATTRIBUTES_MAPPINGitemssplitr,r-CONVERSION_FUNCTIONSr8r?mode PULL_QUEUE%PULL_QUEUES_APP_DEPLOY_DEFAULT_VALUESr/rLrc) queuer3ct_expected_argsr< task_flagrIold_argnew_arg old_arg_listr> old_arg_subdefault_valuess r_PopulateCloudTasksArgsrxsh(&//1/#i O-$(-$#CCIIKg==%L E# U ( ( e)e $  "w2C'C ( ($W-e4 C C '% H H 59 y++ +"HH"HH  " m #/3 ,' 5 5 )/E J J ?U ; Oe,OLP?Lo? rchURVs/sH oS;dM UPM nnU(aS$S$s snf)a8Check whether the queue has any changed attributes based on args provided. Args: args: argparse.Namespace, A placeholder args namespace built to pass on forwards to Cloud Tasks API. Returns: True if any of the queue attributes have changed from the attributes stored in the backend, False otherwise. )rfrFTFr:)argsrmodifiable_argss r_AnyUpdatableFieldsr|8sB%%D%A2B)Ba%D +e+Ds //cSn[RRS[RR R USS5n[R"U5n[R"[R"X S95 g)ajRaises an HTTP exception with status code 400. This function is used to raise the same exceptions generated by the older implementation of `gcloud app delpoy queue.yaml` when it communicated with the Zeus backend over HTTP. Args: msg_body: A string providing more information about the error being raised. Raises: HTTPError: Based on the inputs provided. z&Bad Request Unexpected HTTP status 400N)body) rerror HTTPErrorsixmoves http_client BAD_REQUEST ensure_binaryrreraiserRPCError)msg_bodyexc_msgrs r_RaiseHTTPExceptionrIs_ 5' ,, syy'<'<'H'H!($ 6%   x (( T]]589rcURR(a'URRS:a [S5 ggg)aValidates task retry limit input values for both queues in the YAML file. Args: queue: third_party.appengine.api.queueinfo.QueueEntry, The QueueEntry instance generated from the parsed YAML file. Raises: HTTPError: Based on the inputs provided if value specified is negative. rzIInvalid queue configuration. Task retry limit must not be less than zero.N)retry_parameterstask_retry_limitr)rps r_ValidateTaskRetryLimitr]s> -- --1 2.rcURnUR(dgURGHInUR(dMURR(aHURRS:a.[ SR URR55 URR (aB[[R"URR 55S::a [ S5 URRcMURRcGM URRnURRnXC:dGM>[ S5 GML g)aJValidates jobs configuration parameters in the cron YAML file. The purpose of this function is to mimick the behaviour of the old implementation of `gcloud app deploy cron.yaml` before migrating away from console-admin-hr. The errors generated are the same as the ones previously seen when gcloud sent the batch-request for updating jobs to the Zeus backend. Args: config: A yaml_parsing.ConfigYamlInfo object for the parsed YAML file we are going to process. Raises: HTTPError: Various different scenarios defined in the function can cause this exception to be raised. Nz[Invalid Cron retry parameters: Cannot set retry limit to more than 5 (currently set to {}).rzOInvalid Cron retry parameters: Job age limit must be greater than zero seconds.z]Invalid Cron retry parameters: Min backoff sec must not be greater than than max backoff sec.) parsedcronrjob_retry_limitrrY job_age_limitrr*r0min_backoff_secondsmax_backoff_seconds)config cron_yamljobrDrEs rValidateCronYamlFileConfigrps&"mm)  ^^c     . .   . . 2 ,,2F$$44-6 7    , , jAA""002 367 8  ! "    2 2 >   2 2 >**>> **>>  $ 3 4CrchURnUR(dgURGHnUR(aUR[R:XGaUR (d [ S5 O][R"UR 5nU[R:a)[ SR[RU55 UR(Ga[U5 URR(aB[[R"URR55S::a [ S5 URR (a%URR S:a [ S5 URR"(a%URR"S:a [ S5 URR$(a%URR$S:a [ S5 URR bSURR"b<URR nURR"nXT:a [ S 5 UR&(aUR&S:a'[ S RUR(55 GMUR&[R*:a6[ S RUR([R*55 GMGMGMUR (a [ S 5 UR(a[U5 URRb [ S 5 URR b [ S5 URR"b [ S5 URR$b [ S5 UR,b [ S5 UR&b [ S5 UR.(dGM[ S5 GM g)aOValidates queue configuration parameters in the queue YAML file. The purpose of this function is to mimick the behaviour of the old implementation of `gcloud app deploy queue.yaml` before migrating away from console-admin-hr. The errors generated are the same as the ones previously seen when gcloud sent the batch-request for updating queues to the Zeus backend. Args: config: A yaml_parsing.ConfigYamlInfo object for the parsed YAML file we are going to process. Raises: HTTPError: Various different scenarios defined in the function can cause this exception to be raised. NzPInvalid queue configuration. Refill rate must be specified for push-based queue.zSInvalid queue configuration. Refill rate must not exceed {} per second (is {:.1f}).rzFInvalid queue configuration. Task age limit must be greater than zero.zLInvalid queue configuration. Min backoff seconds must not be less than zero.zLInvalid queue configuration. Max backoff seconds must not be less than zero.zFInvalid queue configuration. Max doublings must not be less than zero.z[Invalid queue configuration. Min backoff sec must not be greater than than max backoff sec.z5Error updating queue "{}": The queue rate is invalid.z5Error updating queue "{}": Maximum bucket size is {}.zTInvalid queue configuration. Refill rate must not be specified for pull-based queue.zKInvalid queue configuration. Can't specify task_age_limit for a pull queue.zPInvalid queue configuration. Can't specify min_backoff_seconds for a pull queue.zPInvalid queue configuration. Can't specify max_backoff_seconds for a pull queue.zJInvalid queue configuration. Can't specify max_doublings for a pull queue.z`Invalid queue configuration. Max concurrent requests must not be specified for pull-based queue.zTInvalid queue configuration. Bucket size must not be specified for pull-based queue.zOInvalid queue configuration. Target must not be specified for pull-based queue.)rrprmr PUSH_QUEUErrr* ConvertRateMAX_RATErYrrtask_age_limitrr0rr max_doublings bucket_sizerfMAX_BUCKET_SIZErr)r queue_yamlrprate_in_secondsrDrEs rValidateQueueYamlFileConfigrsg"}}*    e ::y';';;ZZ  !%00< Y// / ++16$$o,7 8    &  " " 1 1  CC&&557 8;< =    " " 6 6  " " 6 6 :   !  " " 6 6  " " 6 6 :   !  " " 0 0  " " 0 01 4    " " 6 6 B  " " 6 6 B..BB+..BB+  & 5 6      q ELL**   !:!: : ELL**i779 :;   $ %   &  ! ! 0 0 < " #  ! ! 5 5 A " #  ! ! 5 5 A " #  ! ! / / ; " #  & & 2 1 2    & $ %   !K rc8URn[R"[R"55n[R "U5nUR U5Vs0sH-n[RRUR5U_M/ nnU$s snf)aOFetches the current queues data stored in the database. Args: tasks_api: api_lib.tasks.ApiAdapter, Cloud Tasks API needed for doing queue based operations. Returns: A dictionary with queue names as keys and corresponding protobuf Queue objects as values apis.cloudtasks..cloudtasks__messages.Queue ) queuesr ResolveAppLocationr ParseProject ParseLocationListospathbasenamerf) tasks_api queues_client app_location region_refrall_queues_in_db_dicts rFetchCurrentQueuesDatarHs""-''(<(<(>?,$$\2*+8+=+=j+I+Iabggqvv!+I s4BcURn[R"[R"5UR S9n[R "U5R5n[SURU555$)zFetches the current jobs data stored in the database. Args: scheduler_api: api_lib.scheduler.ApiAdapter, Cloud Scheduler API needed for doing jobs based operations. Returns: A list of currently existing jobs in the backend. locations_clientc3$# UHov M g7f)N).0rs r 'FetchCurrentJobsData..js 65Aa5s) jobsr rr r locationsr RelativeNamelistr) scheduler_api jobs_clientrrs rFetchCurrentJobsDatar\si""+'' }/F/FH,$$\2??A* 6))*5 6 66rc "SS5nURnURS:gnURn[UR 55n[ R "S5n U R5SSn [R"US9n U R[R"S[S S 95 /n U HGn U RS S SRS S5nU R!USR#U545 MI /nUR$c/UlUR$GHnUR&U;aUR)UR&5 U"SR#U UR&55n UR+UR&S5n[-UUU 5nUR/S5nU(axU(aqU(dUR0[2R4:XaLUR6UR6R8UR6R:4;aUR=U 5 OcU(a\U(dUUR6UR6R>:Xa1UR0S[2R@4;aURCU 5 [EU5(dGM[ RF"U[2R@URHUSS9n[ RJ"U[2R@US9nU(dUR!SS/5 URLbURLRNOSnURQU UURRURTUU(d[2RVOSU(d[2RXOSURZS9nURU5 U(aGMU(aGMUR0[2R@:XdGMURCU 5 GM UHunUS:XaM UUnUR6UR6R:UR6R84;aMLU"SR#U U55n URCU 5 Mw U$)aPerform a deployment based on the parsed 'queue.yaml' file. Args: tasks_api: api_lib.tasks.ApiAdapter, Cloud Tasks API needed for doing queue based operations. config: A yaml_parsing.ConfigYamlInfo object for the parsed YAML file we are going to process. all_queues_in_db_dict: A dictionary with queue names as keys and corresponding apis.cloudtasks..cloudtasks__messages.Queue objects as values ct_api_version: The Cloud Tasks API version we want to use. Returns: A list of responses received from the Cloud Tasks APIs representing queue states for every call made to modify the attributes of a queue. c$\rSrSrSrSrSrSrg)2DeployQueuesYamlFile.._PlaceholderQueueRefiaA placeholder class to simulate queue_ref resource objects used in CT APIs. This class simulates the behaviour of the resource object returned by tasks.parsers.ParseQueue(...) function. We use this placeholder class instead of creating an actual resource instance because otherwise it takes roughly 2 minutes to create resource instances for a 1000 queues. Attributes: _relative_path: A string representing the full path for a queue in the format: 'projects//locations//queues/' cXlg)z4Initializes the instance and sets the relative path.N_relative_path)self relative_paths r__init__;DeployQueuesYamlFile.._PlaceholderQueueRef.__init__s)rcUR$)a(Gets the string representing the full path for a queue. This is the only function we are currently using in CT APIs for the queue_ref resource object. Returns: A string representing the full path for a queue in the following format: 'projects//locations//queues/' r)rs rr?DeployQueuesYamlFile.._PlaceholderQueueRef.RelativeNames  rrN)__name__ __module__ __qualname____firstlineno____doc__rr__static_attributes__rrr_PlaceholderQueueRefrs * !rrFalser!N) release_trackz--max_burst_size)rFhelpr-_zclear_{}z{}{}r)F)r http_queuetaskTtl tombstoneTtl) retry_config rate_limitsapp_engine_routing_overridetask_ttltask_tombstone_ttl queue_typedefault).rresume_paused_queuesrsetkeysr ParseQueuerr _PushQueueFlagsrWrArgumentrrzreplaceextendrYrprfremovegetrxGetValuermr rnstateDISABLEDPAUSEDResumeRUNNINGrPauser|ParseCreateOrUpdateQueueArgsmessagesGetSpecifiedFieldsMaskrRrSPatchr.r' MAX_TASK_TTLMAX_TASK_TOMBSTONE_TTLrF)rrrct_api_versionrrrrqueues_not_present_in_yaml queue_refqueue_ref_stub task_args expected_argsrrrt responsesrpcur_queue_objectr< rate_to_set queue_configupdated_fieldsrresponse queue_names rDeployQueuesYamlFiler ms.!!:}}*#88GC""-"#8#=#=#?@  %)))+CR0.##.A) 4==!3#BGH-innQ#++C5G':#4#4W#=>?)Je zz// '' 3$V]]>5::%NOI,00TB-e5E.;=O!**+FGK   i&:&::#3#9#9#B#B#3#9#9#@#@#B B 9% "2"8"8"@"@@ tY1122)$  / /77 $L33--^MN Y78  * * 6 ''@@<@ ""!-- ++$?/?''T4DI , ,$$$# HX   K i***)$M P/jY !* -E {{u{{))5;;+?+?@@$V]]>:%NOI "/ rc URURURRURUR (a*[ R"UR R5OSUR (a*[ R"UR R5OSUR (aUR ROSUR (a*[ R"UR R5OSUR (aUR ROS[R"X54 $)zCreates a key from the proto job instance's attributes passed as input. Args: job: An instance of job fetched from the backend. project: The base name of the project. Returns: A tuple of attributes used as a key to identify this job. N)scheduletimeZoneappEngineHttpTarget relativeUri descriptionr.r*r0minBackoffDurationmaxBackoffDuration maxDoublingsmaxRetryDuration retryCountr !ExtractTargetFromAppEngineHostUrl)rr\s r!_CreateUniqueJobKeyForExistingJobrs ll ll )) oo1499 // , ,.FJ1499 // , ,.FJ&)oocoo""4/299 // * *,DH$'OOcoo   //= rcX[RnURnU(GaURc"URcUSUlUSUlOURb URcUR(d USUlUR(a%[ URUR5UlURc USUl[ URUR5UlURc USUlURc USUlggg)aReplaces default values for retry parameters. Retry parameters are set to their default values if not already user defined. These values are only set if the user has defined at least one retry parameter. Also we are limiting min_backoff to a minimum value of 5.0s since the new scheduler API does not support setting a lower value than this. Modifies input `job` argument directly. Args: job: An instance of a parsed YAML job object. NrDrErmax_retry_duration) r CRON_JOB_LEGACY_DEFAULT_VALUESrrrrrrr)rdefaults retry_datas r$_ReplaceDefaultRetryParamsForYamlJobr (s% 5 5(##* &&.&&.(0 '>j$'/ '>j$&&.&&. + +)1-)@ &  ' '),Z-K-K-7-K-K*M &  ' ' /)1-)@ &'*:+I+I+5+I+I(Kj$'!)/!:j'!)*>!?j(Crc URnURUR(a UROSURURU(a UR OSU(a UR OSU(a UROSU(a [R"UR5OSU(aURUR4 $SUR4 $)zCreates a key from the YAML job instance's attributes passed as input. Args: job: An instance of a parsed YAML job object. Returns: A tuple of attributes used as a key to identify this job. UTCN) rrtimezoneurlrrrrr*r0rrr)r retry_paramss r_CreateUniqueJobKeyForYamlJobr&[s%%, llllcll gg oo*6l&&D*6l&&D$0l  d)599  $ $&;?&2l"" jj  9= jj  rcj0nUH*n[X15nXB;a/X$'X$RU5 M, U$)avBuilds a dictionary of unique jobs by attributes. Each key is in this dictionary is based on all the existing attributes of a job. Multiple jobs can map to the same key if all their attributes (schedule, url, timezone, description, etc.) match. Args: existing_jobs: A list of jobs that already exist in the backend. Each job maps to an apis.cloudscheduler..cloudscheduler_messages.Job instance. project: The base name of the project. Returns: A dictionary where a key is built based on a all the job attributes and the value is an apis.cloudscheduler..cloudscheduler_messages.Job instance. )rrW) existing_jobsr\jobs_indexed_dictrr=s r_BuildJobsMappingDictr*ssF" c +C 9C #!!!#&  rc URnUR(aUR[R"URR 5URR [R"URR5[R"URR5URRS9nOSnURURURRRURUR!UR"S9S9UUR$UR&R(UR*UR,(aUR,S9$SS9$)a^Build a proto format job instance matching the input YAML based job. Args: scheduler_api: api_lib.scheduler.ApiAdapter, Cloud Scheduler API needed for doing jobs based operations. yaml_job: A parsed yaml_job entry read from the 'cron.yaml' file. Returns: An cloudscheduler..cloudscheduler__messages.Job instance. )rrrrrN)rP) httpMethodrappEngineRoutingr")rr.rlegacyAppEngineCronrr)rr RetryConfigr*ConvertBackoffSecondsrrConvertTaskAgeLimitrrrJobAppEngineHttpTargetHttpMethodValueValuesEnumGETr$AppEngineRoutingrrr legacy_cronrr#)ryaml_jobrrs rCreateJobInstancer9sT # #( ''%;;  % % 9 9;..<<#77  % % 3 35%;;  % % 9 9;,,<<( LL "6611KKOOll#44X__4M7O&&',,88  $,$5$5x    B BApiAdapter, Cloud Scheduler API needed for doing jobs based operations. config: A yaml_parsing.ConfigYamlInfo object for the parsed YAML file we are going to process. existing_jobs: A list of jobs that already exist in the backend. Each job maps to an apis.cloudscheduler..cloudscheduler_messages.Job instance. Returns: A list of responses received from the Cloud Scheduler APIs representing job states for every call made to create a job. r)rrr rr rrrrrrrstrr*rr r&popr9rWCreatevaluesDeleterf)rrr(rrrrr\existing_jobs_dictrr8job_keyr jobs_lists rDeployCronYamlFilerCs-,mm)""+'' }/F/FH,$$\2??A* GG  S!5!5!78 9',]D)^^NN*84-h7g  &+=+F #'') m 6c{))*:;#&,,.i'/ r)g& .>g)5r __future__rrrrgooglecloudsdk.api_lib.apprgooglecloudsdk.api_lib.tasksrr*googlecloudsdk.callioperr googlecloudsdk.command_lib.tasksr r r r googlecloudsdk.corerrr six.movesrrr0r1 ConvertTargetrlr%r8r?rArLrcrxr|rrrrrr ReleaseTrackBETAr rr r&r*r9rCrrrrNs  '' +M(50624**  C  " ",6,L,L,6,L,L'1'E'E)=&&A*3 l / +.)b.BDN,":(&74t[!|(7*$$)) ^B40@f04!BH5r