
    	                         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\
R                  5      rg)zWait for a job to complete.    )absolute_import)division)unicode_literals)dataproc)util)base)flags)logc                   .    \ rS rSrSr\S 5       rS rSrg)Wait   a  View the output of a job as it runs or after it completes.

View the output of a job as it runs or after it completes.

## EXAMPLES

To see a list of all jobs, run:

  $ gcloud dataproc jobs list

To display these jobs with their respective IDs and underlying REST calls,
run:

  $ gcloud dataproc jobs list --format "table(reference.jobId)" \
    --limit 1 --log-http

To view the output of a job as it runs, run:

  $ {command} job_id
c                     [         R                  " U R                  5       5      n[        R                  " USUR
                  5        g )Nzwait for)dpDataprocReleaseTrackr	   AddJobResourceArgapi_version)clsparserr   s      !lib/surface/dataproc/jobs/wait.pyArgs	Wait.Args3   s1    {{3++-.H	FJ0D0DE    c           
         [         R                  " U R                  5       5      nUR                  R                  R                  5       nUR                  R                  R                  UR                  R                  UR                  UR                  UR                  S95      n[        R                  " UUUSUR                  R                   R"                  R$                  UR                  R                   R"                  R&                  SS9n[(        R*                  R-                  SR/                  UR                  5      5        U$ )N)	projectIdregionjobIdzWaiting for job completionT)message
goal_stateerror_statestream_driver_logz Job [{0}] finished successfully.)r   r   r   CONCEPTSjobParseclientprojects_regions_jobsGetmessages%DataprocProjectsRegionsJobsGetRequestr   r   r   r   WaitForJobTermination	JobStatusStateValueValuesEnumDONEERRORr
   statusPrintformat)selfargsr   job_refr#   s        r   RunWait.Run8   s    {{4,,./Hmm%%'G
//
/
/
3
3??''>>-- 	@ 	!"C 
$
$,$$..CCHH%%//DDJJ C JJ7>>txxHIJr    N)	__name__
__module____qualname____firstlineno____doc__classmethodr   r5   __static_attributes__r7   r   r   r   r      s"    * F Fr   r   N)r<   
__future__r   r   r   googlecloudsdk.api_lib.dataprocr   r   r   googlecloudsdk.callioper   #googlecloudsdk.command_lib.dataprocr	   googlecloudsdk.corer
   Commandr   r7   r   r   <module>rE      s2     " &  ' : 0 ( 5 #34<< 3r   