SrSSKJr SSKJr SSKJr SSKJr SSKJr SSKJ r SSK J r SSK Jr "S S \ R5rg ) z*Waiter utility for api_lib.util.waiter.py.)absolute_import)division)unicode_literals) exceptions)util)"abstract_operation_streamer_poller)logc0\rSrSrSrSrSrSrSrSr g) GceBatchPollerz$Poller for GCE based batch workload.cfU(aURURRRRR URRRRR URRRRR4;agg)See base class.TF)statedataprocmessagesBatchStateValueValuesEnum SUCCEEDED CANCELLEDFAILEDselfbatchs >lib/googlecloudsdk/api_lib/dataproc/poller/gce_batch_poller.pyIsDoneGceBatchPoller.IsDone$sz  $$99CC $$99CC $$99@@!  clURRRUS9nURRRR U5$![ RaKn[R"SRU55 [R"U5(aeSnAgSnAff=f)r)namezGet Batch failed: {}N) rr*DataprocProjectsLocationsBatchesGetRequestclientprojects_locations_batchesGetapitools_exceptions HttpErrorr warningformatrIsClientHttpException)r batch_refrequesterrors rPollGceBatchPoller.Poll.smm$$OO PG ]] ! ! < < @ @ II  ( ( kk)0078 # #E * *  +s.AB3(AB..B3cU(d[R"S5eURURRR R R:XaZUR(d[R"S5 g URR(a[R"S5 g URURRR R R:Xa[R"S5 g SnUR(a)SRX!R5nUSS:waUS- nUS - nUS - n[R"U5e) a<Handles errors. Error handling for batch jobs. This happen after the batch reaches one of the complete states. Overrides. Args: batch: The batch resource. Returns: None. The result is directly output to log.err. Raises: JobTimeoutError: When waiter timed out. JobError: When remote batch job is failed. z&Timed out while waiting for batch job.z$Expected batch job output not found.z:Batch job terminated, but output did not finish streaming.zBatch job is CANCELLED.zBatch job is FAILED.z {} Detail: {}. zRunning auto diagnostics on the batch. It may take few minutes before diagnostics output is available. Please check diagnostics output by running 'gcloud dataproc batches describe' command.N)rJobTimeoutErrorrrrrrrdriver_log_streamerr r&openr stateMessager'JobError)rr err_messages r _GetResultGceBatchPoller._GetResult;s5$   & &'O PP  == ! ! ' ' < < F F G % % :;6 5  # # ( ( H 0 )  == ! ! ' ' < < F F G kk+," +k   %,,[:L:LM r?c !  +Tk 'k    ,,rcU(aBUR(a1URR(aURR$g)rN) runtimeInfo outputUrirs r _GetOutputUriGceBatchPoller._GetOutputUrits0 ""u'8'8'B'B    ( (( rN) __name__ __module__ __qualname____firstlineno____doc__rr,r8r=__static_attributes__r?rrr r s- 7rrr N)rD __future__rrrapitools.base.pyrr$googlecloudsdk.api_lib.dataprocr&googlecloudsdk.api_lib.dataproc.pollerrdataproc_poller_basegooglecloudsdk.corer AbstractOperationStreamerPollerr r?rrrMs; 1&'>60$Y88Yr