
                            S r SSKJr  SSKJr  SSKJr  SSKJr  SSKJr  SSK	J
r
  SSK	Jr  SS	K	Jr  SS
KJr  \R                  " SSS9\R                   " \R"                  R$                  5       " S S\R&                  5      5       5       r\R                  " SSS9\R                   " \R"                  R*                  5       " S S\5      5       5       rg)z$`gcloud tasks queues create command.    )absolute_import)division)unicode_literals)GetApiAdapter)base)	constants)flags)parsers)logFzIThis command is deprecated. Use `gcloud beta tasks queues create` instead)
is_removedwarningc                   L   ^  \ rS rSrSrSSS.rU 4S jr\S 5       rS r	S	r
U =r$ )
CreateAppEngine   sCreate a Cloud Tasks queue.

The flags available to this command represent the fields of a queue that are
mutable.
"          {description}
          as            To create a Cloud Tasks queue:

              $ {command} my-queue
                --max-attempts=10 --max-retry-duration=5s
                --max-doublings=4 --min-backoff=1s
                --max-backoff=10s
                --max-dispatches-per-second=100
                --max-concurrent-dispatches=10
                --routing-override=service:abc
         DESCRIPTIONEXAMPLESc                 <   > [         [        U ]
  " U0 UD6  SU l        g )NF)superr   __init__is_alphaselfargskwargs	__class__s      3lib/surface/tasks/queues/create_app_engine_queue.pyr   CreateAppEngine.__init__9   s    	/4)4:6:DM    c                     [         R                  " U S5        [         R                  " U 5        [         R                  " U [        R
                  R                  SSS9  g Nz	to createTF)release_trackapp_engine_queue
http_queue)r	   AddQueueResourceArgAddLocationFlagAddCreatePushQueueFlagsr   ReleaseTrackBETAparsers    r   ArgsCreateAppEngine.Args=   sF    	fk2	&!	!!'',,	r!   c           	         [        U R                  5       5      nUR                  n[        R                  " UR
                  UR                  5      n[        R                  " U5      n[        R                  " U[        R                  UR                  U R                  5       SS9nU R                  (       d=  UR                  UUUR                  UR                  UR                   UR"                  S9nO1UR                  UUUR                  UR                  UR$                  S9n[&        R(                  " [        R*                  " UR-                  5       5      S5        U$ )NF)r$   r&   )retry_configrate_limitsapp_engine_http_queuestackdriver_logging_config)r1   r2   app_engine_http_targetqueue)r   r*   queuesr
   
ParseQueuer6   locationExtractLocationRefFromQueueRefParseCreateOrUpdateQueueArgsr   
PUSH_QUEUEmessagesr   CreateretryConfig
rateLimitsappEngineHttpQueuestackdriverLoggingConfigappEngineHttpTargetr   CreatedResourceGetConsolePromptStringRelativeName)r   r   apiqueues_client	queue_reflocation_refqueue_configcreate_responses           r   RunCreateAppEngine.RunH   s,   
))+
,CJJM""4::t}}=I99)DL77'')L ==%,,

#//"-- , ? ?%1%J%J - Lo &,,

#//"--!-!A!A - Co &&y'='='?@'Kr!   r   )__name__
__module____qualname____firstlineno____doc__detailed_helpr   staticmethodr.   rM   __static_attributes____classcell__r   s   @r   r   r      s<    

	-"   r!   r   zPThis command group is deprecated. Use `gcloud alpha tasks queues create` insteadc                   F   ^  \ rS rSrSrSSS.rU 4S jr\S 5       rSr	U =r
$ )	AlphaCreateAppEngineh   r   r   au            To create a Cloud Tasks queue:

              $ {command} my-queue
                --max-attempts=10 --max-retry-duration=5s
                --max-doublings=4 --min-backoff=1s
                --max-backoff=10s
                --max-tasks-dispatched-per-second=100
                --max-concurrent-tasks=10
                --routing-override=service:abc
          r   c                 <   > [         [        U ]
  " U0 UD6  SU l        g )NT)r   r[   r   r   r   s      r   r   AlphaCreateAppEngine.__init__   s    	
.??DMr!   c                     [         R                  " U S5        [         R                  " U 5        [         R                  " U [        R
                  R                  SSS9  g r#   )r	   r'   r(   r)   r   r*   ALPHAr,   s    r   r.   AlphaCreateAppEngine.Args   sF    	fk2	&!	!!''--	r!   rO   )rP   rQ   rR   rS   rT   rU   r   rV   r.   rW   rX   rY   s   @r   r[   r[   h   s2    

	-"  r!   r[   N)rT   
__future__r   r   r   googlecloudsdk.api_lib.tasksr   googlecloudsdk.callioper    googlecloudsdk.command_lib.tasksr   r	   r
   googlecloudsdk.corer   	DeprecateReleaseTracksr*   r+   CreateCommandr   r`   r[    r!   r   <module>rk      s    + '  ' 6 ( 6 2 4 # 5HI D%%**+Cd(( C ,ICL 5IJ D%%++,%? % -J%r!   