
                            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                  " \R                   R"                  \R                   R$                  5       " S S\R&                  5      5       rg)z0`gcloud tasks queues create-pull-queue` command.    )absolute_import)division)unicode_literals)GetApiAdapter)base)	constants)flags)parsers)logc                   8    \ rS rSrSrSSS.r\S 5       rS rSr	g	)

CreatePull   a\  Create a pull queue.

The flags available to this command represent the fields of a pull queue
that are mutable.

If you have early access to Cloud Tasks, refer to the following guide for
more information about the different queue target types:
https://cloud.google.com/cloud-tasks/docs/queue-types.
For access, sign up here: https://goo.gl/Ya0AZd
z#
          {description}
          z
          To create a Cloud Tasks pull queue:

              $ {command} my-queue
              --max-attempts=10 --max-retry-duration=10s
         )DESCRIPTIONEXAMPLESc                     [         R                  " U S5        [         R                  " U 5        [         R                  " U 5        g )Nz	to create)r	   AddQueueResourceArgAddLocationFlagAddCreatePullQueueFlags)parsers    -lib/surface/tasks/queues/create_pull_queue.pyArgsCreatePull.Args8   s.    	fk2	&!	!!&)    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9nU R                  5       [        R                  R                  :X  a2  UR                  UU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$ )N)release_track)retry_configrate_limitspull_target)r   r   
queue_typequeue)r   ReleaseTrackqueuesr
   
ParseQueuer    locationExtractLocationRefFromQueueRefParseCreateOrUpdateQueueArgsr   
PULL_QUEUEmessagesr   ALPHACreateretryConfig
rateLimits
pullTargettyper   CreatedResourceGetConsolePromptStringRelativeName)selfargsapiqueues_client	queue_reflocation_refqueue_configcreate_responses           r   RunCreatePull.Run>   s4   
))+
,CJJM""4::t}}=I99)DL77'')	+L
 d//555%,,

#//"--"-- - /o &,,

#//"--!&& - (o &&y'='='?@'Kr    N)
__name__
__module____qualname____firstlineno____doc__detailed_helpstaticmethodr   r:   __static_attributes__r<   r   r   r   r      s1    	- * *
r   r   N)rA   
__future__r   r   r   googlecloudsdk.api_lib.tasksr   googlecloudsdk.callioper    googlecloudsdk.command_lib.tasksr   r	   r
   googlecloudsdk.corer   ReleaseTracksr!   r)   BETACreateCommandr   r<   r   r   <module>rM      sl    7 &  ' 6 ( 6 2 4 # D%%++T->->-C-CD:## : E:r   