d(SrSSKJr SSKJr SSKJr SSKrSSKJr SSK J r SSK J r SS K J r SS KJr SS KJr S rS rSrS9SjrSrSrS:SjrSr\ R4R6SS4SjrSr\ R4R6SS4SjrSrSr Sr!Sr"S;Sjr#Sr$Sr%S r&S!r'Sg)>z0Utilities for flags for `gcloud tasks` commands.)absolute_import)division)unicode_literalsN)tasks)apis) arg_parsers)base) constants) arg_utilscf[R"SSSS9n[R"SSS9n[R"SS S9n[R"S S S9n[R"S S9nURU5 URU5 URU5 [R"S SSSS9n[R"SS9nURU5 [R"SSS9nURU5 URU5 UR U5 UR U5 g)zAdd flags for CMEK Update.z--kms-key-namezFully qualified identifier for the key or just the key ID. The latter requires that the --kms-keyring and --kms-project flags be provided too.Thelprequiredz --kms-keyringz4 KMS keyring of the KMS key. r --location? Google Cloud location for the KMS key. z --kms-projectz> Google Cloud project for the KMS key. z$Flags for Updating CMEK Resource keyz--clear-kms-key store_truezDisables CMEK for Cloud Tasks in the specified location by clearing the Cloud KMS cryptokey from the Cloud Tasks project and CMEK configuration.)actionrrz%Flags for clearing CMEK Resource key.z,Flags for Clearing or Updating CMEK Resource)rmutexN)r Argument ArgumentGroup AddArgument AddToParser) parserkms_key_name_argkms_keyring_argkms_location_argkms_project_argcmek_update_groupclear_kms_key_name_flagcmek_clear_groupcmek_clear_update_groups -lib/googlecloudsdk/command_lib/tasks/flags.pyAddCmekConfigResourceFlagr$sF]] MM / ]]  MM /(( 1 0100!MM   '' 267!.. 9%%&67%%&78v&%%f-cR[R"SSSS9nURU5 g)zAdd flags for CMEK Describe.rTrrrNr rr)rrs r#DescribeCmekConfigResourceFlagr)as.]] v&r%cj[R"SSRU5S9RU5 g)NqueuezThe queue {}. rr rformatrrverbs r#AddQueueResourceArgr0os*--188>?KK r%TFcfU(aSOSn[R"SX1S9nURU5 g)NzThe queue the tasks belong to.zThe queue the task belongs to.z--queuer r()rr plural_tasks descriptionarguments r#AddQueueResourceFlagr5us0 2&F ]]9; J( vr%cVSn[R"SUSS9nURU5 g)Nz'The task ID for the task being created.z --task-idFr r()rr3r4s r# AddTaskIdFlagr7|s':+ ]];[5 I( vr%c~[R"SSRU5S9RU5 [ USS9 g)NtaskzThe task {}. rFr)r rr-rr5r.s r#AddTaskResourceArgsr;s3-- %,,T244?K4Gv.r%c\UcSn[R"SSX!S9nURU5 g)NzThe location where we want to manage the queue or task. If not specified, uses the location of the current project's App Engine app if there is an associated app.rF)hiddenrrr()rrhelptextr4s r#AddLocationFlagr?s8  - ]]5xD( vr%cH[5HnURU5 M gN)_PullQueueFlagsrrflags r#AddCreatePullQueueFlagsrEsdV r%c<U[RR:Xa [5nO;[ U5nU[RR :XaU(d [ U5 U(aU[5- n[USS9 UHnURU5 M g)z%Creates flags related to Push queues.T)is_email_requiredN) r ReleaseTrackALPHA_AlphaPushQueueFlags_PushQueueFlagsBETAAddQueueTypeFlag_HttpPushQueueFlags_AddHttpTargetAuthFlagsrr release_trackapp_engine_queue http_queueflagsrDs r#AddCreatePushQueueFlagsrUs|d''--- "E M *E))...   ""EFd;dVr%c<[5Hn[X5 M grA)rB_AddFlagAndItsClearEquivalentrCs r#AddUpdatePullQueueFlagsrXsd!$/ r%c2U[RR:Xa [5nO;[ U5nU[RR :XaU(d [ U5 U(aU[5[5-- nUHn[XP5 M g)z%Updates flags related to Push queues.N) r rHrIrJrKrLrMrNrOrWrPs r#AddUpdatePushQueueFlagsrZswd''--- "E M *E))...   "%<%> >>Ed!$/r%c[R"SS9nURU5 UR[U55 UR U5 g)NT)r)r rr_EquivalentClearFlagr)rDr update_groups r#rWrWsB##$/,4 /566"r%cURRSS5n[R"USSR UR5S9nU$)Nz--z--clear-rz, Clear the field corresponding to `{}`.rr)namereplacer rr-)rDr` clear_flags r#r\r\sG   4 ,$}} <'006tyy0AC* r%cL[R"SSS9RU5 g)N policy_filez2 JSON or YAML file containing the IAM policy.rr(rs r#AddPolicyFileFlagrfs-- %677B{67Jr%cl[R"SSSRU5S9RU5 g)N--schedule-timeTzy The task's current schedule time. This restriction is to check that the caller is {} the correct task. r'r,r.s r#AddTaskLeaseScheduleTimeFlagris/--$  &,  $ F+r%cbUcSn[R"SS[US9RU5 g)NzrThe number of seconds for the desired new lease duration, starting from now. The maximum lease duration is 1 week.z--lease-durationT)rtyper)r rintr)rr>s r#AddTaskLeaseDurationFlagrms0 KH--"T*{62r%cv[R"S[S[RSS9R U5 g)Nz--limitizc The maximum number of tasks to lease. The maximum that can be requested is 1000. )rkdefaultcategoryr)r rrlLIST_COMMAND_FLAGSrres r#AddMaxTasksToLeaseFlagrrs.--c4$2I2I  ;v r%c`[R"S[5SSS9RU5 g)Nz--typepushz{ Specifies the type of queue. Only available options are 'push' and 'pull'. The default option is 'push'. )rkror)r r_GetQueueTypeArgValidatorrres r#rMrMs+-- $ &   ;v r%cfUR5nURSSS9 URSSSS9 g)N--tagz A tag to filter each task to be leased. If a task has the tag and the task is available to be leased, then it is listed and leased. rz --oldest-tagrzf Only lease tasks which have the same tag as the task with the oldest schedule time. r_add_mutually_exclusive_group add_argument)rtag_filter_groups r#AddFilterLeasedTasksFlagr|sF88:/  |K  r%c[USS9 [5RU5 [5HnURU5 M [ US5 g)z8Add flags needed for creating a pull task to the parser.Tr:N)r5_GetTaskIdFlagr_PullTaskFlags_AddPayloadFlagsrCs r#AddCreatePullTaskFlagsrsBv-v&dV64 r%c[USS9 [5RU5 U(a [5O [ 5nUHnURU5 M [ X5 g)z>Add flags needed for creating a App Engine task to the parser.Tr:N)r5r~r_AlphaAppEngineTaskFlags_AppEngineTaskFlagsr)ris_alpharTrDs r#AddCreateAppEngineTaskFlagsrsNv-v&(0 " $6I6K%dV6$r%c[USS9 [5RU5 [5HnURU5 M [ U5 [ U5 g)z8Add flags needed for creating a HTTP task to the parser.Tr:N)r5r~r_HttpTaskFlagsr _AddAuthFlagsrCs r#AddCreateHttpTaskFlagsr&sHv-v&dV6r%c [R"S[R"S[R SS9SS9[R"SSS 9/$) Nz--max-attemptsT) unlimitedzJ The maximum number of attempts per task in the queue. rkrz--max-retry-durationai The time limit for retrying a failed task, measured from when the task was first run. Once the `--max-retry-duration` time has passed and the task has been attempted --max-attempts times, no further attempts will be made and the task will be deleted. Must be a string that ends in 's', such as "5s". r)r rr BoundedIntsysmaxsizer%r#rBrB0sL mm %%b#++F mm   r%c`[5[R"S[SS9[R"SSS9[R"SSS9[R"S [R "[ 5S S S S0S 9SSRSR[R55S9/-$)Nz--max-doublingsa The time between retries will double maxDoublings times. A tasks retry interval starts at minBackoff, then doubles maxDoublings times, then increases linearly, and finally retries retries at intervals of maxBackoff up to maxAttempts times. For example, if minBackoff is 10s, maxBackoff is 300s, and maxDoublings is 3, then the a task will first be retried in 10s. The retry interval will double three times, and then increase linearly by 2^3 * 10s. Finally, the task will retry at intervals of maxBackoff until the task has been attempted maxAttempts times. Thus, the requests will retry at 10s, 20s, 40s, 80s, 160s, 240s, 300s, 300s. rz --min-backoffz The minimum amount of time to wait before retrying a task after it fails. Must be a string that ends in 's', such as "5s". rz --max-backoffz The maximum amount of time to wait before retrying a task after it fails. Must be a string that ends in 's', such as "5s". z--routing-override:key_type min_length max_length operators KEY:VALUEz If provided, the specified App Engine route is used for all tasks in the queue, no matter what is set is at the task-level. KEY must be at least one of: [{}]. Any missing keys will use the default. , rkmetavarr) rBr rrlrArgDict!_GetAppEngineRoutingKeysValidatorr-joinr APP_ENGINE_ROUTING_KEYSrr%r#_BasePushQueueFlagsrGs   mm  " mm   mm   mm ""8:d %  fTYYy@@ABD=-- -r%c[5[R"S[SS9[R"S[SS9/-$)Nz!--max-tasks-dispatched-per-secondT The maximum rate at which tasks are dispatched from this queue. rz--max-concurrent-tasks The maximum number of concurrent tasks that Cloud Tasks allows to be dispatched for this queue. After this threshold has been reached, Cloud Tasks stops dispatching tasks until the number of outstanding requests decreases. )rr rfloatrlrr%r#rJrJxsG   mm -  mm "" r%c .[R"S[R"[ 5SSSS0S9SSR SR [R55S 9[R"S S S 9[R"S SS[5SS9/$)Nz--http-uri-overriderrrrag If provided, the specified HTTP target URI override is used for all tasks in the queue depending on what is set as the mode. Allowed values for mode are: ALWAYS, IF_NOT_EXISTS. If not set, mode defaults to ALWAYS. KEY must be at least one of: [{}]. Any missing keys will use the default. rrz--http-method-overridez If provided, the specified HTTP method type override is used for all tasks in the queue, no matter what is set at the task-level. rz--http-header-overrideHEADER_FIELD: HEADER_VALUEappenda! If provided, the specified HTTP headers override the existing headers for all tasks in the queue. If a task has a header with the same Key as a queue-level header override, then the value of the task header will be overriden with the value of the queue-level header. Otherwise, the queue-level header will be added to the task headers. Header values can contain commas. This flag can be repeated. Repeated header fields will have their values overridden. rrrkr) r rrr _GetHttpUriOverrideKeysValidatorr-rr HTTP_URI_OVERIDE_KEYS_GetHeaderArgValidatorrr%r#rNrNs mm ""79d % fTYYy>>?@!B" mm "  mm ".%'  1' 'r%cN[5[R"S[SS9[R"S[SS9/-nU[R R :XdU[R R:Xa)UR[R"S[SS95 U$)z$Returns flags needed by push queues.z--max-dispatches-per-secondrrz--max-concurrent-dispatchesrz--log-sampling-ratioz Specifies the fraction of operations to write to Cloud Logging. This field may contain any value between 0.0 and 1.0, inclusive. 0.0 is the default and means that no operations are logged. ) rr rrrlrHrLGAr)rQrTs r#rKrKs   mm '  mm '# %"d'',,, ARARAUAU0U LL    ,r%cD[5[R"SSS9/-$)NrwzC An optional label used to group similar tasks. r)_CommonTaskFlagsr rrr%r#rrs*   mmG# r%c [5[R"SSS9[R"SSS[5SS9/-$) Nz--methodzm The HTTP method to use for the request. If not specified, "POST" will be used. rz--headerrrz An HTTP request header. Header values can contain commas. This flag can be repeated. Repeated header fields will have their values overridden. r)rr rrrr%r#_BasePushTaskFlagsrsK   mmJ& mmJ(D#*@*B   r%cF[5[R"SSSS9/-$)N--urlTz The full URL path that the request will be sent to. This string must begin with either "http://" or "https://". r')rr rrr%r#rrs,   mmGd2! r%c [5[R"S[R"[ 5SSSS0S9SSR SR[R55S 9/-$) Nz --routingrrrrrz The route to be used for this task. KEY must be at least one of: [{}]. Any missing keys will use the default. Routing can be overridden by the queue-level `--routing-override` flag. rr) rr rrrrr-rr rrr%r#_BaseAppEngineTaskFlagsrsl   mm "",M,O./A.14[: fTYYy@@AB D! r%cD[5[R"SSS9/-$)Nrz The relative URL of the request. Must begin with "/" and must be a valid HTTP relative URL. It can contain a path and query string arguments. If not specified, then the root path "/" will be used. rrr rrr%r#rr s* " mmG#& r%cD[5[R"SSS9/-$)Nz--relative-uriz The relative URI of the request. Must begin with "/" and must be a valid HTTP relative URI. It can contain a path and query string arguments. If not specified, then the root path "/" will be used. rrrr%r#rrs+ " mm$,& r%c0[R"SSSSS9$)Nr9TASK_ID?a4 The task to create. If not specified then the system will generate a random unique task ID. Explicitly specifying a task ID enables task de-duplication. If a task's ID is identical to that of an existing task or a task that was deleted or completed recently then the call will fail. Because there is an extra lookup cost to identify duplicate task names, tasks created with IDs have significantly increased latency. Using hashed strings for the task ID or for the prefix of the task ID is recommended. )rnargsrr rrr%r#r~r~s!      r%c.[R"SSS9/$)Nrhz} The time when the task is scheduled to be first attempted. Defaults to "now" if not specified. rrrr%r#rr1s  mm%- r%cUR5nU(a!URSSS9 URSSS9 g URSSS9 URSS S9 g ) z"Adds either payload or body flags.z--payload-contentzR Data payload used by the task worker to process the task. rz--payload-filezn File containing data payload used by the task worker to process the task. z--body-contentzT HTTP Body data sent to the task worker processing the task. z --body-filezp File containing HTTP body data sent to the task worker processing the task. Nrx)rr payload_groups r#rr:s|557- 2:/7 /7}4r%cURSS9nURSS9nURSSSS9 URSS S9 URS S9nURS SS S9 URS SS9 g)Add flags for http auth.zx How the request sent to the target when executing the task should be authenticated. rOpenId Connectz--oidc-service-account-emailTu The service account email to be used for generating an OpenID Connect token to be included in the request sent to the target when executing the task. The service account must be within the same project as the queue. The caller must have 'iam.serviceAccounts.actAs' permission for the service account. r'z--oidc-token-audience The audience to be used when generating an OpenID Connect token to be included in the request sent to the target when executing the task. If not specified, the URI specified in the target will be used. OAuth2z--oauth-service-account-emailt The service account email to be used for generating an OAuth2 access token to be included in the request sent to the target when executing the task. The service account must be within the same project as the queue. The caller must have 'iam.serviceAccounts.actAs' permission for the service account. z--oauth-token-scope The scope to be used when generating an OAuth2 access token to be included in the request sent to the target when executing the task. If not specified, 'https://www.googleapis.com/auth/cloud-platform' will be used. N)ryadd_argument_grouprz)r auth_group oidc_group oauth_groups r#rrOs2292*,,2B,C* 84  19 --8-<+ :T!08r%c$[R"SSS9n[R"SS9n[R"SUSS9nURU5 [R"S S S9nURU5 [R"S S9n[R"S US S9nURU5 [R"SSS9nURU5 URU5 URU5 UbUR U5 XEXx/$)rTz If specified, all `Authorization` headers in the HttpRequest.headers field will be overridden for any tasks executed on this queue. )rrrrz*--http-oidc-service-account-email-overriderr'z#--http-oidc-token-audience-overriderrz+--http-oauth-service-account-email-overriderz!--http-oauth-token-scope-overrider)r rrrr) rrGrroidc_email_argoidc_token_argroauth_email_argoauth_scope_args r#rOrOus!!  *!!'78*==2   . (==+ . (""1+MM3   //*MM) //* $ % 6" / KKr%c[R"SSRSR[R 555$)Nc(U[R;$rA)r rks r#3_GetAppEngineRoutingKeysValidator..sY666r%4Only the following keys are valid for routing: [{}].r)rCustomFunctionValidatorr-rr rrr%r#rrs8  , ,6<CC ))I55 68 99r%c[R"SSRSR[R 555$)Nc(U[R;$rA)r rrs r#r2_GetHttpUriOverrideKeysValidator..sY444r%rr)rrr-rr rrr%r#rrs8  , ,4<CC ))I33 46 77r%c[R"SSRSR[R 555$)Nc(U[R;$rA)r VALID_QUEUE_TYPESrs r#r+_GetQueueTypeArgValidator..sY000r%z/Only the following queue types are valid: [{}].r)rrr-rr rrr%r#rurus8  , ,07>> ))I// 02 33r%c0[R"SS5$)Nz ^(\S+):(.+)$z2Must be of the form: "HEADER_FIELD: HEADER_VALUE".)rRegexpValidatorrr%r#rrs  $ $K MMr%c [R"S[R"[R [R "U55RRSSS9$)Nz--response-viewbasiczTask response view.)rohelp_str) r ChoiceEnumMapperrGetMessagesModule tasks_api_libAPI_NAMEApiVersionFromReleaseTrack0CloudtasksProjectsLocationsQueuesTasksGetRequestResponseViewValueValuesEnum)rQs r#GetTaskResponseViewMapperrsU  # #    2 2 ON""$ &&r%)TF)FNrA)F)NF)?__doc__ __future__rrrrgooglecloudsdk.api_librrgooglecloudsdk.api_lib.utilrgooglecloudsdk.callioperr googlecloudsdk.command_lib.tasksr $googlecloudsdk.command_lib.util.apisr r$r)r0r5r7r;r?rErHrrUrXrZrWr\rfrirmrrrMr|rrrrBrrJrNrKrrrrrrr~rrrrOrrrurrrr%r#rsF7&' 9,/(6:?.D '  / ##&& 00##&& 0.#K ,3  !%..b((V#'"3"3"6"6>  $ (*#L;L|973M &r%