dZddlmZddlmZddlmZddlmZddlmZddlm Z ddl m Z dd l m Z Gd d e jZy ) z#The configs waiters create command.)absolute_import)division)unicode_literals)util) arg_parsers)base)flags)logc4eZdZdZddiZedZdZdZy)CreatezsCreate waiter resources. This command creates a new waiter resource with the specified name and parameters. EXAMPLESa To create a waiter in "my-config" with success and failure paths nested under "/status", run: $ {command} my-waiter --config-name=my-config --timeout=15m --success-cardinality-path=/status/success --success-cardinality-number=5 --failure-cardinality-path=/status/failure --failure-cardinality-number=1 This waiter will wait for at most 15 minutes for the first of two possible scenarios: 1) five or more variables are written to the /status/success/ path; or 2) one or more variables are written to the /status/failure/ path. To create a waiter without a failure path, run: $ {command} my-waiter --config-name=my-config --timeout=15m --success-cardinality-path=/status/success --success-cardinality-number=5 This waiter will wait until 5 or more success variables are written, or the 15 minute timeout elapses. c tj|tjj ||j dt jddjtjdd|j dd d |j d d t jd d |j dd|j ddt jd d |j ddy)zArgs is called by calliope to gather arguments for this command. Args: parser: An argparse parser that you can use to add arguments that go on the command line after this command. Positional arguments are allowed. z --timeout1s{0}s) lower_bound upper_boundTz The amount of time to wait before failing with DEADLINE_EXCEEDED. See $ gcloud topic datetimes for information on duration formats. )typerequiredhelpz--success-cardinality-pathz-The path where success variables are written.)rrz--success-cardinality-numberz1The minimum required number of success variables.)r)rrdefaultz--failure-cardinality-pathz-The path where failure variables are written.)rz--failure-cardinality-numberz1The minimum required number of failure variables.namezThe waiter name.N) r AddRequiredConfigFlagr ASYNC_FLAG AddToParser add_argumentrDurationformatrMAX_WAITER_TIMEOUT BoundedInt)parsers 4lib/surface/runtime_config/configs/waiters/create.pyArgsz Create.Args9s 'OO'   ! !d.4mm&*&=&=/?@    $ < & @  # # 2   $ <> & @  # # 2   %78c tj}tj}tj|j|}|j }|j }|j|j|j|j}|jr8|j|j|j|j}nd}|j|jtj|||j!|j#dj%|j&||} t)j*||j,rM||_|j0j2j5|j#} |j7| } n8d|_tj8|} tj:| rd|_tj>| S) a3Run 'runtime-configs waiters create'. Args: args: argparse.Namespace, The arguments that this command was invoked with. Returns: The associated waiter operation. Raises: HttpException: An http error response was received while executing api request. )pathnumber) cardinalityNr)rtimeoutsuccessfailure)parentwaiter)r) r WaiterClientMessagesParseWaiterNamer projectsId configsId EndCondition Cardinalitysuccess_cardinality_pathsuccess_cardinality_numberfailure_cardinality_pathfailure_cardinality_numberr 0RuntimeconfigProjectsConfigsWaitersCreateRequest ConfigPathWaiter RelativeNamerr)r CreatedResourceasync__async_resourceclientMESSAGES_MODULE-RuntimeconfigProjectsConfigsWaitersGetRequestGet WaitForWaiterIsFailedWaiter exit_code FormatWaiter) selfargs waiter_clientmessageswaiter_resourceprojectconfigr*r+resultrequests r"Runz Create.Runes%%'M}}H**499d;O((G  & &F##((..22) $G $$%%**0044+ &gg  ! !AA??7F3??$113 dll3 # B  F( {{ -d%%55??)668@:  )f!d!!/2f  V $   V $$r$c|jretjjtjjdj |jj yy)zCalled after resources are displayed if the default format was used. Args: unused_resources_were_displayed: Unused. zEThe wait command can be used to monitor the progress of waiter [{0}].N)r@r statusPrintrName)rIunused_resources_were_displayeds r"Epilogz Create.EpilogsS   jj jj %vd&:&:&?&?&ABDr$N) __name__ __module__ __qualname____doc__ detailed_help staticmethodr#rRrXr$r"r r s:-*)9)9VD%L Dr$r N)r\ __future__rrr%googlecloudsdk.api_lib.runtime_configrgooglecloudsdk.callioperr)googlecloudsdk.command_lib.runtime_configr googlecloudsdk.corer CreateCommandr r_r$r"rfs8 *&'6/(;#XDT  XDr$