SrSSKJr SSKJr SSKJr SSKrSSKJr SSKJ r SSKJ r SS K J r SS K J r SS KJr SS KJr SS KJr SSKJr SSKJr SSKrSSKJr SSKJr \R4R6R8R:r"SS\R>5r "SS\R>5r!"SS\R>5r""SS\#5r$Sr%Sr&Sr'SOSjr(SOSjr)Sr*S r+S!r,S"r-S#r.S$r/S%\ R`RbS&4S'jr2S(r3S)r4\ R`Rb4S*jr5\ R`Rb4S+jr6\ R`Rb4S,jr7SPS-jr8SPS.jr9S/r:SPS0jr;SPS1jrS4r?S5r@S6rAS7rBS8rCS9rDS:rES;rFSQS<jrGS=rHS>rIS?rJS@rKSArLSBrMSCrNSDrOSErPSFrQSGrRSHrSSIrTSJrUSKrVSLrWSMrXSNrYg)Rz;Utilities for parsing arguments to `gcloud tasks` commands.)absolute_import)division)unicode_literalsN)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)rMrN) 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.FromQueueTypeAndReleaseTrack9s 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.) rUrZrVr[rWr\rXr]rYr^)selfall_configs_and_prefixesrgprefixs 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)rkrgrmfields_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.)rqrnupdaterx)rkconfig_to_maskrgrms rGetConfigToUpdateMaskMapping8QueueUpdatableConfiguration.GetConfigToUpdateMaskMappings?VN CCED>>vNOF rch[URR55[URR55-[URR55-[UR R55-[UR R55-$N)listrUrrrVrWrXrY)rks r AllConfigs&QueueUpdatableConfiguration.AllConfigss ""'') *T$2B2B2G2G2I-J J 11668 9 : !!&&( ) * 00557 8 9:rrN)rrrrr classmethodrraGArhrnrxr}rrrrrr&r&6s?3261B1B1E1EJJX  :rr&cj[RR[5[R S9$)N collection)r REGISTRYParse_PROJECTr PROJECTS_COLLECTIONrrr ParseProjectrs.    ! !j.. " 00rch[RRUS[0[R S9$N projectsIdparamsr)r rrrr LOCATIONS_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)rematchrsgroup) 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 rrr QUEUES_COLLECTIONRequiredFieldOmittedExceptionr ResolveAppLocationrrrr)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 rrr TASKS_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 ParseTaskIdr8s/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)rrrrrs kms_projectr)rrfull_kms_key_name parse_results rParseKmsUpdateArgsrPs!% D+$T%6%67, q/K))     --|DD+/+;+;t''$$&& D & 33rcZUR(a UROSn[5nX!4$)zParses KMS describe args.Nrr)rr project_ids rParseKmsDescribeArgsrks#!% D+z*   rcXUR(a UROSn[5U4$)zParses KMS clear args.Nr)rrs rParseKmsClearArgsrss !% D+ [  rcUR5nUS [RRSU[R S9nU$)NqueuesIdr)rr rrr r)rrrs rExtractLocationRefFromQueueRefrzsG    & 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-rF pullTargetrGrHF)r-rFrSrRrHtype)r-rFrSr:rH)rrarb_ParseAppEngineHttpTargetArgs_ParseHttpTargetArgsQueue_ParseRetryConfigArgs_ParseAlphaRateLimitsArgs_ParsePullTargetArgsrc_ParseRateLimitsArgs"_ParseStackdriverLoggingConfigArgs_ParseAppEngineHttpQueueArgs_ParseQueueType"_ParseAppEngineRoutingOverrideArgs)rremessages is_updaterf http_queueapp_engine_http_targetrXs 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@rAhttp_oauth_email_overridehttp_oauth_scope_overridehttp_oidc_email_overridehttp_oidc_audience_override) rHr;r<r= oauthTokenserviceAccountEmailscope oidcTokenaudience) queue_configr?r@rArrrrs 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)rGappEngineRoutingserviceAttributeErrorhostrssplit)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>)rOclear_max_burst_sizec3,># UH oT;v M g7frr).0flagrs r >_SpecifiedArgs.._IsSpecifiedWrapper..psB"1$#+/sF) IsSpecifiedrUnknownDestinationExceptionany)rhttp_queue_argsspecified_args_objects` r_IsSpecifiedWrapper+_SpecifiedArgs.._IsSpecifiedWrapperVsaO " . .s 33  4 4 : :cB"1B??  s4AA)rtr)r args_listrrclear_args_listas` rrrSsD @/7@Ay!*1-yOA #%@ AABs:c,[[XU55$)z@Returns whether there are known arguments in the specified list.)rr)rr!rs rrr|s ^1j I JJrc$SRU5$)Nzclear_{}rs)rs rrtrts   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*r1)r*r.r/r0N) r r_r RetryConfigr,_AddMaxAttemptsFieldsFromArgsr`r2r3r4)rrerrrrUs 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.r7r8r)r5r6N)r r`r RateLimitsr7r8rrerrs rrrs^I(((@57#,.   $($H$H44  66.)rcU[R:XaW[U/SQUS9(aD[US5(a UROSnUR UR URUS9$gg)r/rLrrON)rIrJrK)r r`rrrOr0rMrN)rrerrrOs rrrs{I(((    't-=>>D   #== $ > >#  %% )rcU[R:wa+[US/US9(aURURS9$gg)zCParses the attributes of 'args' for Queue.stackdriverLoggingConfig.rPr)rQN)r r_rStackdriverLoggingConfigrPr1s rrrsNI(((34K  , ,-- - //L)rc\U[R:XaU(dUR5$gg)z5Parses the attributes of 'args' for Queue.pullTarget.N)r r_ PullTarget) unused_argsrerrs 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)rrr r_rTypeValueValuesEnumPULLPUSHr1s rrrs^tVi.B.B!BY)))) >> - - 2 22  + + 0 00rcjU[R:Xa[XU5nUcgURUS9$g)z>Parses the attributes of 'args' for Queue.appEngineHttpTarget.Nr:)r r`rAppEngineHttpTargetrrerr9s 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)r;r=r<rr) r r`_ParseHttpRoutingOverrideArgsr HttpTargetHttpMethodValueValuesEnumr@upper_ParseHttpTargetOAuthArgs_ParseHttpTargetOidcArgs_ParseHttpTargetHeaderArg)rrer 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)r r`rAppEngineHttpQueuer?s rrrsB9'''9 (  & &!1 '  (rcU[R:Xa3URS5(aUR"S0URD6$gg)z5Parses the attributes of 'args' for AppEngineRouting.r9Nr)r r`rAppEngineRoutingr9)rrers rrrsD9''' *++  & & ?)>)> ?? (rc^URS5(a[SSU0URD6$g)z1Parses the attributes of 'args' for HTTP Routing.r?rNr)r_ParseUriOverrider?rrs rrArAs0 )**  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) UriOverrideSchemeValueValuesEnumrDint%UriOverrideEnforceModeValueValuesEnum PathOverride QueryOverride)rrVrrWrTquerymodeuri_override_enforce_modes rrQrQs 00@ T$ @@N      ((d(3**u*=6  88rcrU[R:Xa#UR[U5URS9$g)N)payloadtag)r r  PullMessage_ParsePayloadArgsrf)rrrs rrr7s5)%%%   (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)rr<re relativeUrlheadersr) r APP_ENGINE_TASKroutingrOrAppEngineHttpRequestrCrkrDrhurl_ParseHeaderArg HeadersValuerrrrorIs rrr<s)+++59\\!!1DLL1t !% 0 0 : :00JJ @D  ( ( !$'TXX ( = = J JL ) MM ,rcURS5(a [R"URSS9nO$URS5(a URnOg[ R "U5$)N payload_fileFbinarypayload_content)rrReadFromFileOrStdinrvryrEncode)rres rrhrhJs\ n%%,,T->->uMG )**""G    g &&rc U[R:XaUR(aUR"S0URD6OSnUR S5(a3UR R URR55OSnUR X4[U5UR[UUR R5S9$g)rjNrk)rr<body relativeUrirmr) r rnrorOrrprCrkrD_ParseBodyArgs relative_urirrrsrts rrrTs)+++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.rkN)rmr<r}rqrr) r HTTP_TASKr HttpRequestrCrkrDrrrsrrq_ParseOAuthArgs_ParseOidcArgs)rrrrIs rrrbs)%%% $ 0 0 : :''AA @D   &:&:&G&GH^D%9txx"42 0  22&rcURS5(a [R"URSS9nO$URS5(a URnOg[ R "U5$)N body_fileFrw body_content)rrrzrrrr{)rr}s rrrnsY k""  ) )$.. GD ''   D    d ##rcxURS5(a$URURURS9$g)Noauth_service_account_emailrr)r OAuthTokenroauth_token_scoperRs rrrxsC 344    <<$$  && rcxURS5(a$URURURS9$g)Noidc_service_account_emailrr)r OidcTokenroidc_token_audiencerRs rrrsC 233    ;;))  ++ rcxURS5(a$URURURS9$g)NrBr)rrrBrCrRs rrErEsC ABB    JJ22  44 rcxURS5(a$URURURS9$g)NrDr)rrrDrErRs rrFrFsC @AA    II77  99 rcUR(aD[[UR5VVs0sHup#X#_M nnn[R"XA5$gs snnfr)headerr_SplitHeaderArgValuerDictToAdditionalPropertyMessage)r headers_valuekv headers_dicts rrrrrsH [[%()=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.rA)rr)r) rrrrAr itemsHeaderOverrideHeaderencoder ) rrmap_rrrrrrheader_overrides rrGrGs $ ,--143L3LMMM <%%' (E  //SZZ\H0Jo kk/" +sB7c$SRU5$)Nz{}sr&)lease_durations rFormatLeaseDurationrs n %%rcUR(agURS5(aSRUR5$g)Nztag_function=oldest_tag()rfztag="{}") oldest_tagrrsrfrs rParseTasksLeaseFilterFlagsrs7 __ & e   TXX &&rc[RRURS[0[ R S9R5$r)r rrnamerr rSelfLink)rs r QueuesUriFuncrsA    ! ! jjH %,, " ./7hj9rc[RRURS[0[ R S9R5$r)r rrrrr rrrs r TasksUriFuncrsA    ! ! iiH %++ " -.6XZ8rc[RRURS[0[ R S9R5$r)r rrrrr rrrs rLocationsUriFuncrsA    ! ! iiH %// " 12:rsB&' %(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