3SrSSKJr SSKJr SSKJr SSKJr SSKJ r SSKJr SSKJ r SSK J r SS K J r SS KJr SS KJr SS KJr SS KJr SSKJr SSKJr "SS\5rSr"SS\5r"SS\5rSrg)z"Utilities for Cloud Workflows API.)absolute_import)division)unicode_literals) 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 ) WorkflowsClient2z8Client 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__5s8((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_levelrczexecution-history-basiczexecution-history-detailedtagsz/tags cannot be updated for an existing workflow),r/Workflowr SetSourceSetDescriptionSetServiceAccountrParseCreateArgs LabelsValue SetLabelsr r!r$ SetKmsKey IsSpecifiedUserEnvVarsValuelenrYUSER_ENV_VARS_LIMITr ArgumentTypeErrorformatCLEAR_ENVIRONMENTSetUserEnvVars userEnvVarsadditionalPropertieskeyvalueupdater\r]argparse ArgumentErrorUpdateUserEnvVarsCallLogLevelValueValuesEnumr ChoiceToEnumraSetWorkflowLoggingArg$ExecutionHistoryLevelValueValuesEnumrf#SetWorkflowExecutionHistoryLevelArgSetWorkflowsTagsArg TagsValue)r3args old_workflowr%rDrSlabelsenv_varspvcall_log_level_enum log_levelexecution_history_level_enum history_levels rBuildWorkflowFromArgs%WorkflowsClient.BuildWorkflowFromArgsqs}}%%'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) rREGISTRYParser9r OperationsClientr-r/WorkflowsOperationPollerrvrHrWaitFor)r3 operationr? operation_refrpollerprogress_strings rWaitForOperation WorkflowsClient.WaitForOperations&&,,<-M..t{{DMMJJ  2 2!F ?EEO >>& AArr1r-r/N) rrrrrr5r<rIrRrrrrrrr(r(2s&@= ","**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_executionsr1r2s rr5 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. TNrcrbrdrg)rC execution {message} error_format)r/ Executionr_(disableConcurrencyQuotaOverflowBufferingrrr r callLogLevelrexecutionHistoryLevelCWorkflowexecutionsProjectsLocationsWorkflowsExecutionsCreateRequestr;r1rIr= HttpErrorr HttpException) r3r?datararfroverflow_buffering_disabledrrrrJes rrIWorkflowExecutionClient.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. Nr8rr) r get_cached_execution_idr/@WorkflowexecutionsProjectsLocationsWorkflowsExecutionsGetRequestr;r1r<r=rrr)r3 execution_refr@rs rr<WorkflowExecutionClient.Get7s335mmm\\  ' ' )]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}.) r rr ExecutionsPollerrvrHrr TimeoutError_TIMEOUT_MESSAGEAbortWaitError)r3rrrs rWaitForExecution(WorkflowExecutionClient.WaitForExecutionLs335m  * *d CF>EEO ^^    '+!!       ; B B-      ! ! , 3 3M B s A''A7Cr)NNNF) rrrrrr5rIr<rrrrrrrs,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) r __future__rrrapitools.base.pyrr=googlecloudsdk.api_lib.utilrr googlecloudsdk.api_lib.workflowsr r googlecloudsdk.callioper r $googlecloudsdk.command_lib.util.apisr $googlecloudsdk.command_lib.util.argsr$googlecloudsdk.command_lib.workflowsrgooglecloudsdk.corer Exceptionrr&objectr(rrrrrrsu)&'9,2.29/(:<6)M9M6wBfwBt|f|BFr