
                             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r
S	rS
rSrSrSr\R                   R"                  4S jrSS jrS rS rS rS rS rS rS rS rg)z7List command formats and transforms for `gcloud tasks`.    )absolute_import)division)unicode_literals)base)	constants)parsersan  table(
    name.basename():label="QUEUE_NAME",
    queuetype():label=TYPE,
    state,
    rateLimits.maxConcurrentTasks.yesno(no="unlimited").format("{0}").sub("-1", "unlimited"):label="MAX_NUM_OF_TASKS",
    rateLimits.maxTasksDispatchedPerSecond.yesno(no="unlimited"):label="MAX_RATE (/sec)",
    retryConfig.maxAttempts.yesno(no="unlimited"):label="MAX_ATTEMPTS")a  table(
    name.basename():label="QUEUE_NAME",
    queuetype():label=TYPE,
    state,
    rateLimits.maxConcurrentDispatches.yesno(no="unlimited").format("{0}").sub("-1", "unlimited"):label="MAX_NUM_OF_TASKS",
    rateLimits.maxDispatchesPerSecond.yesno(no="unlimited"):label="MAX_RATE (/sec)",
    retryConfig.maxAttempts.yesno(no="unlimited").format("{0}").sub("-1", "unlimited"):label="MAX_ATTEMPTS")aw  table(
    name.basename():label="QUEUE_NAME",
    state,
    rateLimits.maxConcurrentDispatches.yesno(no="unlimited").format("{0}").sub("-1", "unlimited"):label="MAX_NUM_OF_TASKS",
    rateLimits.maxDispatchesPerSecond.yesno(no="unlimited"):label="MAX_RATE (/sec)",
    retryConfig.maxAttempts.yesno(no="unlimited").format("{0}").sub("-1", "unlimited"):label="MAX_ATTEMPTS")aj  table(
    name.basename():label="TASK_NAME",
    tasktype():label=TYPE,
    createTime,
    scheduleTime,
    status.attemptDispatchCount.yesno(no="0"):label="DISPATCH_ATTEMPTS",
    status.attemptResponseCount.yesno(no="0"):label="RESPONSE_ATTEMPTS",
    status.lastAttemptStatus.responseStatus.message.yesno(no="Unknown")
        :label="LAST_ATTEMPT_STATUS")aA  table(
    name.basename():label="TASK_NAME",
    tasktype():label=TYPE,
    createTime,
    scheduleTime,
    dispatchCount.yesno(no="0"):label="DISPATCH_ATTEMPTS",
    responseCount.yesno(no="0"):label="RESPONSE_ATTEMPTS",
    lastAttempt.responseStatus.message.yesno(no="Unknown")
        :label="LAST_ATTEMPT_STATUS")zAtable(
     locationId:label="NAME",
     name:label="FULL_NAME")c                    U[         R                  R                  :H  nU[         R                  R                  :H  nU(       d  U(       a!  U R                  R                  S[        05        U R                  R                  U(       a  [        OU(       a  [        O[        5        U R                  R                  [        R                  5        g )N	queuetype)r   ReleaseTrackALPHABETAdisplay_infoAddTransforms_TransformQueueType	AddFormat_ALPHA_QUEUE_LIST_FORMAT_BETA_QUEUE_LIST_FORMAT_QUEUE_LIST_FORMAT
AddUriFuncr   QueuesUriFunc)parserversionis_alphais_betas       4lib/googlecloudsdk/command_lib/tasks/list_formats.pyAddListQueuesFormatsr   P   s    ))///(t((---'
%%{4G&HI"*!(.@B 	  !6!67    c                     U R                   R                  S[        05        U R                   R                  U(       a  [        O[
        5        U R                   R                  [        R                  5        g )Ntasktype)	r   r   _TransformTaskTyper   _ALPHA_TASK_LIST_FORMAT_TASK_LIST_FORMATr   r   TasksUriFunc)r   r   s     r   AddListTasksFormatsr$   \   sT    ##Z1C$DE!)/@B  !5!56r   c                     U R                   R                  [        5        U R                   R                  [        R
                  5        g N)r   r   _LOCATION_LIST_FORMATr   r   LocationsUriFunc)r   s    r   AddListLocationsFormatsr)   c   s1     56  !9!9:r   c                 B    SU ;   =(       d    SU ;   =(       a    U S   S:H  $ )N
pullTargettypePULL rs    r   _IsPullQueuer1   h   s$    			Cv{BqyF/BCr   c                 r    SU ;   =(       d,    SU ;   =(       d     SU ;   =(       d    SU ;   =(       a    U S   S:H  $ )NappEngineHttpTargetappEngineHttpQueueappEngineRoutingOverrider,   PUSHr.   r/   s    r   _IsPushQueuer7   l   sE      1
$ 0(<(A 0
$
)0Q;.1V9.1r   c                     SU ;   $ )NpullMessager.   r/   s    r   _IsPullTaskr:   t       	!	r   c                     SU ;   $ )NappEngineHttpRequestr.   r/   s    r   _IsAppEngineTaskr>   x   s    	1	$$r   c                     SU ;   $ )NhttpRequestr.   r/   s    r   _IsHttpTaskrA   |   r;   r   c                     [        U 5      (       a  [        R                  $ [        U 5      (       a  [        R                  $ g r&   )r1   r   
PULL_QUEUEr7   
PUSH_QUEUEr/   s    r   r   r      s1    !__!__ r   c                     [        U 5      (       a  [        R                  $ [        U 5      (       a  g[	        U 5      (       a  gg )Nz
app-enginehttp)r:   r   rC   r>   rA   r/   s    r   r    r       s6    ^^a^^ r   N)F)__doc__
__future__r   r   r   googlecloudsdk.callioper    googlecloudsdk.command_lib.tasksr   r   r   r   r   r!   r"   r'   r   GAr   r$   r)   r1   r7   r:   r>   rA   r   r    r.   r   r   <module>rL      s    > &  ' ( 6 4K p p ) )    *.):):)=)= 	87;
D1% r   