def __track_job(self):
        """Poll job status while active"""
        while not self.__verify_job_has_started():
            time.sleep(self.__POLL_TIME)
            self.__logger.debug("Waiting for Kubernetes job " + self.uu_name + " to start")
        self.__print_kubectl_hints()

        status = self.__get_job_status()
        while status == "RUNNING":
            self.__logger.debug("Kubernetes job " + self.uu_name + " is running")
            time.sleep(self.__POLL_TIME)
            status = self.__get_job_status()

        assert status != "FAILED", "Kubernetes job " + self.uu_name + " failed"

        # status == "SUCCEEDED"
        self.__logger.info("Kubernetes job " + self.uu_name + " succeeded")
        self.signal_complete()
def __track_job ( self ) : while not self . __verify_job_has_started ( ) : time . sleep ( self . __POLL_TIME ) self . __logger . debug ( "Waiting for Kubernetes job " + self . uu_name + " to start" ) self . __print_kubectl_hints ( ) status = self . __get_job_status ( ) while status == "RUNNING" : self . __logger . debug ( "Kubernetes job " + self . uu_name + " is running" ) time . sleep ( self . __POLL_TIME ) status = self . __get_job_status ( ) assert status != "FAILED" , "Kubernetes job " + self . uu_name + " failed" self . __logger . info ( "Kubernetes job " + self . uu_name + " succeeded" ) self . signal_complete ( )
Poll job status while active