
                            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  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\R0                  5      5       rg)zCommand for deleting jobs.    )absolute_import)division)unicode_literals)	execution)base)connection_context)deletion)flags)pretty_print)resource_args)serverless_operations)concept_parsers)presentation_specs)log)
console_ioc                   N    \ rS rSrSrSSS.r\S 5       r\S 5       rS r	S	 r
S
rg)Delete#   Delete a job.z#
          {description}
          zJ
          To delete a job:

              $ {command} job-name
          )DESCRIPTIONEXAMPLESc                     [         R                  " S[        R                  " 5       SSSS9n[        R
                  " U SS9  [        R                  " U/5      R                  U 5        g )NJOBzJob to delete.TF)requiredprefixes)default_async_for_cluster)	r   ResourcePresentationSpecr   GetJobResourceSpecr
   AddAsyncFlagr   ConceptParserAddToParser)parserjob_presentations     lib/surface/run/jobs/delete.py
CommonArgsDelete.CommonArgs2   s_    )BB((* 
$ !!#3"45AA&I    c                 .    [         R                  U 5        g )N)r   r%   )r"   s    r$   ArgsDelete.Args@   s    
fr'   c                 $   [         R                  " U[        R                  R                  U R                  5       5      nUR                  R                  R                  5       n[        R                  " U5       nSR                  UR                  5      n[        R                  " 5       (       a  U R                  X45      (       a  US-  n[        R                   " USSS9  ["        R$                  " X4R&                  UR(                  UR*                  5        SSS5        UR*                  (       a0  [,        R.                  " SR                  UR                  5      5        g[0        R2                  " UR                  S5        g! , (       d  f       Nq= f)r   zJob [{}] will be deleted.zU This job is currently executing; all running executions will be stopped and deleted.T)messagethrow_if_unattendedcancel_on_noNzJob [{}] is being deleted.job)r   GetConnectionContextr
   ProductRUNReleaseTrackCONCEPTSr/   Parser   ConnectformatjobsIdr   	CanPromptHasRunningExecutionsPromptContinuer	   r   GetJob	DeleteJobasync_r   Successr   DeletedResource)selfargsconn_contextjob_refclientr,   s         r$   Run
Delete.RunD   s   %::emm!2!2!4L mm%%'G		&	&|	4+227>>Bg					D$=$=g$N$N$	
 "
 oog}}f.>.>L 
5 {{7>>w~~NO	'..%0! 
5	4s   9BF
Fc                     SR                  [        R                  UR                  S9nUR	                  UR                  5       USSS9 H  n  g   g)Nz:{label} = {name}, run.googleapis.com/servingState = Active)labelname   )limit	page_sizeTF)r7   r   	JOB_LABELr8   ListExecutionsParent)rA   rD   rE   label_selector_s        r$   r:   Delete.HasRunningExecutions\   sc     	EKK%%GNN 	L 	
 
 "".Q #   r'    N)__name__
__module____qualname____firstlineno____doc__detailed_helpstaticmethodr%   r)   rF   r:   __static_attributes__rT   r'   r$   r   r   #   sJ    		- J J  10r'   r   N)rY   
__future__r   r   r   googlecloudsdk.api_lib.runr   googlecloudsdk.callioper   googlecloudsdk.command_lib.runr   r	   r
   r   r   r   (googlecloudsdk.command_lib.util.conceptsr   r   googlecloudsdk.corer   googlecloudsdk.core.consoler   UniverseCompatibleCommandr   rT   r'   r$   <module>rf      s_    ! &  ' 0 ( = 3 0 7 8 @ D G # 2 CT\\ C Cr'   