3SrSSKJr SSKJr SSKJr SSKJr SSKJr SSKJ r SSK J r SSK J r SS K Jr SS KJr SS KJr SS KJr "S S\5rSr"SS\5r"SS\5rSrg)z"Utilities for Cloud Workflows API.) exceptions)apis)waiter)cache) poller_utils) arg_parsers)base) arg_utils) labels_util)flags) resourcesc\rSrSrSrSrg)UnsupportedReleaseTrackError zDRaised when requesting API version for an unsupported release track.N)__name__ __module__ __qualname____firstlineno____doc____static_attributes__r1lib/googlecloudsdk/api_lib/workflows/workflows.pyrr sLrrcU[RR:XagU[RR:XagU[RR:Xag[ U5e)Nv1alpha1v1betav1)r ReleaseTrackALPHABETAGAr) release_tracks rReleaseTrackToApiVersionr#$sRd''--- ))... )),,,  &} 55rc<\rSrSrSrSrSrSrSrSr Sr S r g ) WorkflowsClient/z8Client for Workflows service in the Cloud Workflows API.c[R"SU5UlURRUlURR Ulg)N workflows)rGetClientInstanceclientMESSAGES_MODULEmessagesprojects_locations_workflows_serviceself api_versions r__init__WorkflowsClient.__init__2s8((kBDKKK//DMKK<RASS R+U S 9S 9e [RB"XtU5 URS 5(aYURRRDn [FRH"URJU /S QS9n [RL"XU5 URS5(aYURRRNn [FRH"URPU /SQS9n [RR"XU5 URS5(a!Ub[&R>RASSS 9e[RT"XURRRV5 XE4$s snfs snf)aeCreates a workflow from command-line arguments. Args: args: The arguments of the gcloud command. old_workflow: The workflow from previous revision. release_track: The gcloud release track used in the command. Returns: workflow: The consturcted Workflow message from the passed in arguments. updated_fields: The workflow fields that are updated. N set_env_vars env_vars_filez3too many environment variables, limit is {max_len}.)max_lenclear_env_varsupdate_env_varsremove_env_varszkey {k} is not found.)k)argumentmessagecall_log_levelnonez log-all-callszlog-errors-onlyzlog-none valid_choicesexecution_history_levelr`zexecution-history-basiczexecution-history-detailedtagsz/tags cannot be updated for an existing workflow),r,Workflowr SetSourceSetDescriptionSetServiceAccountr ParseCreateArgs LabelsValue SetLabelsr rr! SetKmsKey IsSpecifiedUserEnvVarsValuelenrVUSER_ENV_VARS_LIMITrArgumentTypeErrorformatCLEAR_ENVIRONMENTSetUserEnvVars userEnvVarsadditionalPropertieskeyvalueupdaterYrZargparse ArgumentErrorUpdateUserEnvVarsCallLogLevelValueValuesEnumr ChoiceToEnumr^SetWorkflowLoggingArg$ExecutionHistoryLevelValueValuesEnumrc#SetWorkflowExecutionHistoryLevelArgSetWorkflowsTagsArg TagsValue)r0args old_workflowr"rArPlabelsenv_varspvcall_log_level_enum log_levelexecution_history_level_enum history_levels rBuildWorkflowFromArgs%WorkflowsClient.BuildWorkflowFromArgsns}}%%'HN OODN3 8 DN;  ( ( mm$$00F OOFn5)),,, oodn5h  . ) ).. --((99>    / * * t!! "U%>%> >--CJJ33K  .. --((99?    * + +** 8~>h  + , ,"--BB B EE177NB   ,,-  + , ,"--BB B EE177NB  %%A ] &&44/666;5  & h.A  * + +"mm44PP**       ##IH  3 4 4 MM " " G G %"..  ( ( (  11 ^ 5  & ! !l&>""00E1    $--00::  ##q  s !Q8,!Q=c@[RRURSS9n[R "UR UR5n[R"UUUS9nSRUR55n[R"XSU5$)z9Waits until the given long-running operation is complete.z'workflows.projects.locations.operations) collection)r( operationsr<z&Waiting for operation [{}] to complete) r REGISTRYParser6rOperationsClientr*r,WorkflowsOperationPollerrsrErWaitFor)r0 operationr< operation_refrpollerprogress_strings rWaitForOperation WorkflowsClient.WaitForOperations&&,,<-M..t{{DMMJJ  2 2!F ?EEO >>& AArr.r*r,N) rrrrrr2r9rFrOrrrrrrr%r%/s&@= ","**g$RBrr%c<\rSrSrSrSrS SjrSrSrSr g) WorkflowExecutionClientzLClient for Workflows Execution service in the Cloud Workflows Execution API.c[R"SU5UlURRUlURR Ulg)Nworkflowexecutions)rr)r*r+r,'projects_locations_workflows_executionsr.r/s rr2 WorkflowExecutionClient.__init__s9(()={KDKKK//DMKKGGDMrNcrURR5nX'lU(aSUlUbXWlUbCUS:wa=URRR n[ R"UU/SQS9UlUbCUS:wa=URRRn [ R"UU /SQS9Ul URRUR5US9n URRU 5$![R an ["R$"U SS 9eSn A ff=f) a]Creates a Workflow execution. Args: workflow_ref: Resource reference to the Workflow to execute. data: Argments to use for executing the workflow. call_log_level: Level of call logging to apply during execution. execution_history_level: Level of execution history to apply for the execution. labels: Labels associated to the execution. overflow_buffering_disabled: If set to true, the execution will not be backlogged when the concurrency quota is exhausted. Backlogged executions start when the concurrency quota becomes available. Returns: Execution: The workflow execution. TNr`r_rard)r@ execution {message} error_format)r, Executionr\(disableConcurrencyQuotaOverflowBufferingrr~r r callLogLevelrexecutionHistoryLevelCWorkflowexecutionsProjectsLocationsWorkflowsExecutionsCreateRequestr8r.rFr: HttpErrorr HttpException) r0r<datar^rcroverflow_buffering_disabledrrrrGes rrFWorkflowExecutionClient.Creates.2 '')I";?i8 !n&> MM33OO(55    i + #v - -- ! ! F F#)2(>(> ! & )i%bb((*icJB ]] ! !* --  # #B  $ $Q[ AABs-DD6D11D6cUc[R"5nURRUR 5S9nUR R U5$![Ran[R"USS9eSnAff=f)zGets a workflow execution. Args: execution_ref: Resource reference to the Workflow execution to get. Returns: Workflow: The workflow execution if it exists, an error exception otherwise. Nr5rr) rget_cached_execution_idr,@WorkflowexecutionsProjectsLocationsWorkflowsExecutionsGetRequestr8r.r9r:rrr)r0 execution_refr=rs rr9WorkflowExecutionClient.Get4s335mmm\\  ' ' )]GB ]]  w ''  # #B  $ $Q[ AABsAB 0BB c Uc[R"5n[R"US9nSR UR 55n[ R"UUUSSSSS9$![ Ra+ [ R"SR U[55e[ Ra& [ R"S R U55ef=f) zPWaits until the given execution is complete or the maximum wait time is reached.)workflow_executionz&Waiting for execution [{}] to completedi\&g?i`)pre_start_sleep_ms max_wait_msexponential_sleep_multiplierwait_ceiling_msz/Execution {0} has not finished in 24 hours. {1}z Aborting wait for execution {0}.) rrrExecutionsPollerrsrErr TimeoutError_TIMEOUT_MESSAGEAbortWaitError)r0rrrs rWaitForExecution(WorkflowExecutionClient.WaitForExecutionIs335m  * *d CF>EEO ^^    '+!!       ; B B-      ! ! , 3 3M B s A''A7Cr)NNNF) rrrrrr2rFr9rrrrrrrs,TH" "'ABFB*rrzThe execution may still be underway remotely and may still succeed; use gcloud list and describe commands or https://console.developers.google.com/ to check resource state.N)rapitools.base.pyrr:googlecloudsdk.api_lib.utilrr googlecloudsdk.api_lib.workflowsrrgooglecloudsdk.callioperr $googlecloudsdk.command_lib.util.apisr $googlecloudsdk.command_lib.util.argsr $googlecloudsdk.command_lib.workflowsr googlecloudsdk.corer Exceptionrr#objectr%rrrrrrsn):,2.29/(:<6)M9M6wBfwBt|f|BFr