tSrSSKrSSKJr SSKJr SSKJr SSKJr SSKJ r SSK J r SS K J r SS K J r SS KJr SS KJr SSKrSS KJr SSKJr \ R,R.R0R2r"SS\ R65r"SS\ R65r"SS\ R65r"SS\5r Sr!Sr"Sr#SLSjr$SLSjr%Sr&Sr'Sr(Sr)S r*S!r+S"\RXRZS#4S$jr.S%r/S&r0\RXRZ4S'jr1\RXRZ4S(jr2\RXRZ4S)jr3SMS*jr4SMS+jr5S,r6SMS-jr7SMS.jr8S/r9S0r:S1r;S2rS5r?S6r@S7rAS8rBSNS9jrCS:rDS;rES<rFS=rGS>rHS?rIS@rJSArKSBrLSCrMSDrNSErOSFrPSGrQSHrRSIrSSJrTSKrUg)Oz;Utilities for parsing arguments to `gcloud tasks` commands.N)encoding)base) parser_errors)app) constants) exceptions) properties) resources) console_io) http_encoding)filter)mapc\rSrSrSrSrg)NoFieldsSpecifiedError&zAError for when calling an update method with no fields specified.N__name__ __module__ __qualname____firstlineno____doc____static_attributes__r/lib/googlecloudsdk/command_lib/tasks/parsers.pyrr&sIrrc\rSrSrSrSrg)FullTaskUnspecifiedError*zCreates QueueUpdatableConfiguration from the given parameters.N maxAttemptsmaxRetryDuration) max_attemptsmax_retry_duration retryConfig maxDoublings minBackoff maxBackoffr(r) max_doublings min_backoff max_backoffmaxTasksDispatchedPerSecondmaxConcurrentTasks)max_tasks_dispatched_per_secondmax_concurrent_tasksrouting_overrideappEngineRoutingOverride uriOverride httpMethodheaderOverrideszoauthToken.serviceAccountEmailzoauthToken.scopezoidcToken.serviceAccountEmailzoidcToken.audiencehttp_uri_overridehttp_method_overridehttp_header_override)http_oauth_service_account_email_overridehttp_oauth_token_scope_override(http_oidc_service_account_email_override!http_oidc_token_audience_override rateLimitsappEngineHttpTarget httpTargetmaxDispatchesPerSecondmaxConcurrentDispatches maxBurstSizemax_dispatches_per_secondmax_concurrent_dispatchesmax_burst_sizelog_sampling_ratio samplingRatioappEngineHttpQueuestackdriverLoggingConfig)rJrK) retry_config rate_limitsapp_engine_routing_override http_targetstackdriver_logging_configretry_config_mask_prefixrate_limits_mask_prefix'app_engine_routing_override_mask_prefixhttp_target_mask_prefix&stackdriver_logging_config_mask_prefixr PULL_QUEUE PUSH_QUEUEr ReleaseTrackALPHABETA)cls queue_type release_trackconfigs rFromQueueTypeAndReleaseTrack8QueueUpdatableConfiguration.FromQueueTypeAndReleaseTrack6s UFFF)+F&F(*F%&*F#%)F"59F2%)F"48F1Y)))' 2f)6f%h Mg y++ + $++11 1)"4+''  0M$8   :. * !0"/$  +8')5&9N6)5&` M_ D--22 2)"4+''  *B)B,   :. * !0"/$ " !/- )+8')5&9M6)5&8R5P MK*"4+''  *B)B   :. * !0"/$ " !/- )+8')5&9;6)5&8R5 Mrc:URUR4URUR4URUR 4UR UR4URUR4/nUVVs/sHup#U(dMX#4PM snn$s snnf)zEReturns the initialized configs as a list of (config, prefix) tuples.) rRrWrSrXrTrYrUrZrVr[)selfall_configs_and_prefixesrdprefixs r"_InitializedConfigsAndPrefixTuples>QueueUpdatableConfiguration._InitializedConfigsAndPrefixTupless   D99:  4778 ) ) 5 5 7  4778 ( ( 4 4 6  %= $<  V $<  s ; B Bc[5nUR5H6nXnU(aSRX%5X4'OXSU'X4U[U5'M8 U$)zEBuild a map from each arg and its clear_ counterpart to a mask field.z{}.{})dictkeysformat_EquivalentClearArg)rhrdrjfields_to_maskfield output_fields r_GetSingleConfigToMaskMapping9QueueUpdatableConfiguration._GetSingleConfigToMaskMappingsWVN]l  'v D ,u3A3Hn(/0  rc[5nUR5H%up#URURX#55 M' U$)zFBuilds mapping from config fields to corresponding update mask fields.)rnrkupdateru)rhconfig_to_maskrdrjs rGetConfigToUpdateMaskMapping8QueueUpdatableConfiguration.GetConfigToUpdateMaskMappings?VN CCED>>vNOF rch[URR55[URR55-[URR55-[UR R55-[UR R55-$N)listrRrorSrTrUrV)rhs r AllConfigs&QueueUpdatableConfiguration.AllConfigss ""'') *T$2B2B2G2G2I-J J 11668 9 : !!&&( ) * 00557 8 9:rrN)rrrrr classmethodrr^GArerkrurzrrrrrr#r#3s?3261B1B1E1EJJX  :rr#cj[RR[5[R S9$)N collection)r REGISTRYParse_PROJECTrPROJECTS_COLLECTIONrrr ParseProjectrs.    ! !j.. " 00rch[RRUS[0[R S9$N projectsIdparamsr)r rrrrLOCATIONS_COLLECTION)locations r ParseLocationrs4    ! !H %// " 11rc[R"SU5nU(a0SRURS5URS55$U$)aParses a full queue reference and returns an abridged version. Args: queue_string: A full qualifying path for a queue which includes project and location, e.g. projects/PROJECT/locations/LOCATION/queues/QUEUE Returns: A shortened string for the full queue ref which has only the location and the queue (LOCATION/QUEUE). For example: 'projects/myproject/location/us-east1/queue/myqueue' => 'us-east1/myqueue' z@projects\/.*\/locations\/(?P.*)\/queues\/(?P.*)z{}/{}rqueue)rematchrpgroup) queue_stringrs rGetConsolePromptStringrsF ((I % >>%++j15;;w3G HH rcU(dgSn[RRU[RS9nU$![R ay U=(d [ R"[55n[U5n[RRXRURS.[RS9nU$f=f)zParses an id or uri for a queue. Args: queue: An id, self-link, or relative path of a queue resource. location: The location of the app associated with the active project. Returns: A queue resource reference, or None if passed-in queue is Falsy. Nr)r locationsIdr) r rrrQUEUES_COLLECTIONRequiredFieldOmittedExceptionrResolveAppLocationrrrr)rr queue_ref app_location location_refs r ParseQueuers  ) 0""((4=4O4O)QI   0 00Es55lnEL .L""(( %<%<&2&>&>@..)0I 0s,:B CCcU(aUR5OSn[RRU[R US9$![R a [S5ef=f)zParses an id or uri for a task.N)rrzDMust specify either the fully qualified task path or the queue flag.)AsDictr rrrTASKS_COLLECTIONrr)taskrrs r ParseTaskr)sq!*9   &P    # #D/8/I/I+1 $ 33  0 0P "N PPPs ,A A(c@UR(a UR$S$)zParses an id for a task.N)task_idargss r ParseTaskIdr5s/4/rcU(dg[R"SU5nU(aBURS5URS5URS5URS5/$g)z9Parses and retrieves the segments of a full KMS key name.Nzjprojects\/(?P.*)\/locations\/(?P.*)\/keyRings\/(?P.*)\/cryptoKeys\/(?P.*)projectrkeyringkey)rrr) kms_key_namers rParseFullKmsKeyNamer:s`   ((s %  I J I E   rcUR(a UROSnSn[UR5nUbUSnURnO~UR(amUR(a\UR(aKSR UR (a UR O [ 5UURURS9n[ 5X!4$)zParses KMS key value.Nzbprojects/{kms_project_id}/locations/{location_id}/keyRings/{kms_keyring}/cryptoKeys/{kms_key_name})kms_project_id location_id kms_keyringr)rrrrrp kms_projectr)rrfull_kms_key_name parse_results rParseKmsUpdateArgsrMs!% D+$T%6%67, q/K))     --|DD+/+;+;t''$$&& D & 33rcZUR(a UROSn[5nX!4$)zParses KMS describe args.Nrr)rr project_ids rParseKmsDescribeArgsrhs#!% D+z*   rcXUR(a UROSn[5U4$)zParses KMS clear args.Nr)rrs rParseKmsClearArgsrps !% D+ [  rcUR5nUS [RRSU[R S9nU$)NqueuesIdr)rr rrrr)rrrs rExtractLocationRefFromQueueRefrwsG    & Z##)) 6i&D&D*F, rFTc nU[RR:XaQ[XU5nU(a [ XU5OSnUR [ XX#SS9[XX#5[XX#5UUS9$U[RR:XaZU(a [ XU5OSnUR [ XX#SS9[XX#5[XX#5[XU5U[XX#5S9$U(a [ XU5OSnUR [ XX#SS9[XX#5[XX#5[XU5US9$)zParses queue level args.NT)is_alpha)r*rC pullTargetrDrEF)r*rCrPrOrEtype)r*rCrPr7rE)rr^r__ParseAppEngineHttpTargetArgs_ParseHttpTargetArgsQueue_ParseRetryConfigArgs_ParseAlphaRateLimitsArgs_ParsePullTargetArgsr`_ParseRateLimitsArgs"_ParseStackdriverLoggingConfigArgs_ParseAppEngineHttpQueueArgs_ParseQueueType"_ParseAppEngineRoutingOverrideArgs)rrbmessages is_updaterc http_queueapp_engine_http_targetrUs rParseCreateOrUpdateQueueArgsrs{d''---: (=GTx8D >>) hD - h ((N2   ))...>) hE ((N!C h" 8 h  Tx C    =GTx8D >>) hE ((N!C h" "D h"    rc$URbURROSnURbURROSnURbURROSnURb7URRb URRR OSnURb7URRb URRR OSnURb7URRb URRR OSnURb7URRb URRROSnUUUUUUUS.$)zHReturns a pair of each http target attribute and its value in the queue.N)r<r=r>http_oauth_email_overridehttp_oauth_scope_overridehttp_oidc_email_overridehttp_oidc_audience_override) rEr8r9r: oauthTokenserviceAccountEmailscope oidcTokenaudience) queue_configr<r=r>rrrrs rGetHttpTargetArgsrs  ,))   ,((   ,--   ! ! -%%00<((<<    ! ! -%%00<((..    ! ! -%%//;'';;    ! ! -%%//;''00  -22#<#<":%@ rcJSnURRRnU(aU$SnURRRnU(dgSR U5nXC;aUR US5S$S$![a Nmf=f![a NQf=f)aExtracts any target (service) if it exists in the appEngineRouting field. Args: job: An instance of job fetched from the backend. project: The base name of the project. Returns: The target if it exists in the URL, or if it is present in the service attribute of the appEngineRouting field, returns None otherwise. Some examples are: 'alpha.some_project.uk.r.appspot.com' => 'alpha' 'some_project.uk.r.appspot.com' => None Nz.{}.rr)rDappEngineRoutingserviceAttributeErrorhostrpsplit)jobrtargethost_url delimiters r!ExtractTargetFromAppEngineHostUrlrs &  $ $ 5 5 = =F M( &&77<>@,.<=nsc"n+= T6tyyI,?,??v K !!>sB&c~^U4Sjn/nU(aUVs/sHn[U5PM nn[X1U-5$s snf)z:Returns the list of known arguments in the specified list.c>^/SQnTRT5$![Ra$ TS;d[U4SjU55(agef=f)aWrapper function for Namespace.IsSpecified function. We need this function to be support being able to modify certain queue attributes internally using `gcloud app deploy queue.yaml` without exposing the same functionality via `gcloud tasks queues create/update`. Args: arg: The argument we are trying to check if specified. Returns: True if the argument was specified at CLI invocation, False otherwise. r;)rLclear_max_burst_sizec3,># UH oT;v M g7fr}r).0flagr s r >_SpecifiedArgs.._IsSpecifiedWrapper..msB"1$#+/sF) IsSpecifiedrUnknownDestinationExceptionany)r http_queue_argsspecified_args_objects` r_IsSpecifiedWrapper+_SpecifiedArgs.._IsSpecifiedWrapperSsaO " . .s 33  4 4 : :cB"1B??  s4AA)rqr )r args_listrrclear_args_listas` rrrPsD @/7@Ay!*1-yOA #%@ AABs:c,[[XU55$)z@Returns whether there are known arguments in the specified list.)rr)rrrs rrrys ^1j I JJrc$SRU5$)Nzclear_{}rp)r s rrqrq~s   3 rc|U[R:Xa9[USS/US9(a'URURS9n[ XU5 U$U[R :Xa[[U/SQUS9(aHURURURURURS9n[ XU5 U$gg)z6Parses the attributes of 'args' for Queue.retryConfig.r(r)r)r'r.)r'r+r,r-N) rr\r RetryConfigr)_AddMaxAttemptsFieldsFromArgsr]r/r0r1)rrbrrrrRs rrrsI(((~/CD#,.''00(2L!$h? I(((N#,.''00''D4D4D##(%L"$h? .)rcURS5(a6URcU(aSUlgSUlgURUlgg)Nr(T)rr(unlimitedAttemptsr&)r config_objectrs rr&r&sE n%%  *. '$& !"&"3"3m&rcU[R:Xa7[USS/US9(a$URURUR S9$gg)5Parses the attributes of 'args' for Queue.rateLimits.r4r5r)r2r3N)rr]r RateLimitsr4r5rrbrrs rrrs^I(((@57#,.   $($H$H44  66.)rcU[R:XaW[U/SQUS9(aD[US5(a UROSnUR UR URUS9$gg)r,rIrrLN)rFrGrH)rr]rrrLr-rJrK)rrbrrrLs rrrs{I(((    't-=>>D   #== $ > >#  %% )rcU[R:wa+[US/US9(aURURS9$gg)zCParses the attributes of 'args' for Queue.stackdriverLoggingConfig.rMr)rNN)rr\rStackdriverLoggingConfigrMr.s rrrsNI(((34K  , ,-- - //L)rc\U[R:XaU(dUR5$gg)z5Parses the attributes of 'args' for Queue.pullTarget.N)rr\ PullTarget) unused_argsrbrrs rrrs)9'''     1:'rc[US5(aUR[R:XdU[R:Xa'U(d URR R $URR R$)z/Parses the attributes of 'args' for Queue.type.r)rrrr\rTypeValueValuesEnumPULLPUSHr.s rrrs^tVi.B.B!BY)))) >> - - 2 22  + + 0 00rcjU[R:Xa[XU5nUcgURUS9$g)z>Parses the attributes of 'args' for Queue.appEngineHttpTarget.Nr7)rr]rAppEngineHttpTargetrrbrr6s rrrsI9'''9 ($   ' '!1 ( 33 (rcVU[R:Xa[X5nURS5(a3URR UR R55OSn[X5n[X5nUc UcUcUcgUR U[X5UUUS9$g)z5Parses the attributes of 'args' for Queue.HttpTarget.r=N)r8r:r9rr) rr]_ParseHttpRoutingOverrideArgsr HttpTargetHttpMethodValueValuesEnumr=upper_ParseHttpTargetOAuthArgs_ParseHttpTargetOidcArgs_ParseHttpTargetHeaderArg)rrbr uri_override http_method oauth_token oidc_tokens rrrs9'''0@L   2 3 3 55  % % + + - /9= ,D;K)$9J            1$A  '(rcbU[R:Xa[XU5nURUS9$g)z=Parses the attributes of 'args' for Queue.appEngineHttpQueue.r:N)rr]rAppEngineHttpQueuer<s rrrsB9'''9 (  & &!1 '  (rcU[R:Xa3URS5(aUR"S0URD6$gg)z5Parses the attributes of 'args' for AppEngineRouting.r6Nr)rr]rAppEngineRoutingr6)rrbrs rrr sD9''' *++  & & ?)>)> ?? (rc^URS5(a[SSU0URD6$g)z1Parses the attributes of 'args' for HTTP Routing.r<rNr)r_ParseUriOverrider<rrs rr>r>s0 )**  Ih I$2H2H II rc NU(a)URRUR55OSnU(a [U5OSnU(a)URR UR55OSnURUUUUR US9UR US9US9$)z1Parses the attributes of 'args' for URI Override.N)path) queryParams)schemerport pathOverride queryOverrideuriOverrideEnforceMode) UriOverrideSchemeValueValuesEnumrAint%UriOverrideEnforceModeValueValuesEnum PathOverride QueryOverride)rrSrrTrQquerymodeuri_override_enforce_modes rrNrNs 00@ T$ @@N      ((d(3**u*=6  88rcrU[R:Xa#UR[U5URS9$g)N)payloadtag)rr PullMessage_ParsePayloadArgsrc)rrrs rrr4s5)%%%   (9$(?TXX  NN&rc U[R:XaUR(aUR"S0URD6OSnUR S5(a3UR R URR55OSnUR X4[U5UR[UUR R5S9$g)>Parses the attributes of 'args' for Task.appEngineHttpRequest.Nmethod)rr9rb relativeUrlheadersr) rAPP_ENGINE_TASKroutingrLrAppEngineHttpRequestr@rhrAreurl_ParseHeaderArg HeadersValuerrrrlrFs rrr9s)+++59\\!!1DLL1t !% 0 0 : :00JJ @D  ( ( !$'TXX ( = = J JL ) MM ,rcURS5(a [R"URSS9nO$URS5(a URnOg[ R "U5$)N payload_fileFbinarypayload_content)rr ReadFromFileOrStdinrsrvr Encode)rrbs rrereGs\ n%%,,T->->uMG )**""G    g &&rc U[R:XaUR(aUR"S0URD6OSnUR S5(a3UR R URR55OSnUR X4[U5UR[UUR R5S9$g)rgNrh)rr9body relativeUrirjr) rrkrlrLrrmr@rhrA_ParseBodyArgs relative_urirorprqs rrrQs)+++59\\!!1DLL1t !% 0 0 : :00JJ @D  ( ( D !t/@/@ ( = = J JL ) MM ,rc nU[R:XaURS5(a3URR UR R 55OSnUR[XRR5U[U5UR[X5[X5S9$g)z5Parses the attributes of 'args' for Task.httpRequest.rhN)rjr9rzrnrr) r HTTP_TASKr HttpRequestr@rhrArorpr|rn_ParseOAuthArgs_ParseOidcArgs)rrrrFs rrr_s)%%% $ 0 0 : :''AA @D   &:&:&G&GH^D%9txx"42 0  22&rcURS5(a [R"URSS9nO$URS5(a URnOg[ R "U5$)N body_fileFrt body_content)rr rwrrr rx)rrzs rr|r|ksY k""  ) )$.. GD ''   D    d ##rcxURS5(a$URURURS9$g)Noauth_service_account_emailrr)r OAuthTokenroauth_token_scoperOs rrrusC 344    <<$$  && rcxURS5(a$URURURS9$g)Noidc_service_account_emailrr)r OidcTokenroidc_token_audiencerOs rrr~sC 233    ;;))  ++ rcxURS5(a$URURURS9$g)Nr?r)rrr?r@rOs rrBrBsC ABB    JJ22  44 rcxURS5(a$URURURS9$g)NrAr)rrrArBrOs rrCrCsC @AA    II77  99 rcUR(aD[[UR5VVs0sHup#X#_M nnn[R"XA5$gs snnfr})headerr_SplitHeaderArgValuerDictToAdditionalPropertyMessage)r headers_valuekv headers_dicts rrorosH [[%()=t{{%KL%KTQAD%KLL  3 3L PPLsAcLURSS5upXR54$)N:r)rlstrip)header_arg_valuervalues rrrs%%%c1-*# lln rcz/nURS5(a[[UR5VVs0sHup4X4_M nnn[ UR 55nUHOupxUR URUR5UR5S9S9n URU 5 MQ U$s snnf)zCConverts header values into a list of headers and returns the list.r>)rr)r) rrrr>ritemsHeaderOverrideHeaderencoder) rrmap_rrrrrrheader_overrides rrDrDs $ ,--143L3LMMM <%%' (E  //SZZ\H0Jo kk/" +sB7c$SRU5$)Nz{}sr#)lease_durations rFormatLeaseDurationrs n %%rcUR(agURS5(aSRUR5$g)Nztag_function=oldest_tag()rcztag="{}") oldest_tagrrprcrs rParseTasksLeaseFilterFlagsrs7 __ & e   TXX &&rc[RRURS[0[ R S9R5$r)r rrnamerrrSelfLink)rs r QueuesUriFuncrsA    ! ! jjH %,, " ./7hj9rc[RRURS[0[ R S9R5$r)r rrrrrrrrs r TasksUriFuncrsA    ! ! iiH %++ " -.6XZ8rc[RRURS[0[ R S9R5$r)r rrrrrrrrs rLocationsUriFuncrsA    ! ! iiH %// " 12:rNrrrerrr|rrrBrCrorrDrrrrrrrrrsB %(106**)22     ! ! ) ) 3 3JZ--JEz//E)9)9 v:&v:r0 1*6 P0 &46!!##&& ?D;|"LL'+&7&7&:&:F$,0+<+<+?+?M*.):):)=)= " &BRK  $). 46%"/! 13:"  80O M' M 2$Q  "&'98