galaxy_importer/ansible_test/runners/openshift_job.py
def wait_on_pod_ready(self):
        """Wait until job's pod initializes, pulls image, and starts running."""

        self.log.info('Creating pod...')
        for i in range(API_CHECK_RETRIES):
            pods = self.get_pods()
            if len(pods) < 1:
                time.sleep(API_CHECK_DELAY_SECONDS)
                continue
            break

        if len(pods) < 1:
            self.cleanup()
            raise exceptions.AnsibleTestError('Could not create pod associated with job')

        self.log.info('Scheduling pod and waiting until it is running...')
        for i in range(API_CHECK_RETRIES):
            pods = self.get_pods()
            pod_phase = pods[0]['status']['phase']
            if pod_phase != 'Pending':
                return
            time.sleep(API_CHECK_DELAY_SECONDS)

        self.log.debug(pods[0]['status'])
        self.cleanup()
        raise exceptions.AnsibleTestError('Could not start pod associated with job')
Wait until job's pod initializes, pulls image, and starts running.
Wait until job's pod initializes, pulls image, and starts running.
Wait until job ' s pod initializes pulls image and starts running .
def wait_on_pod_ready(self):
        self.log.info('Creating pod...')
        for i in range(API_CHECK_RETRIES):
            pods = self.get_pods()
            if len(pods) < 1:
                time.sleep(API_CHECK_DELAY_SECONDS)
                continue
            break
        if len(pods) < 1:
            self.cleanup()
            raise exceptions.AnsibleTestError('Could not create pod associated with job')
        self.log.info('Scheduling pod and waiting until it is running...')
        for i in range(API_CHECK_RETRIES):
            pods = self.get_pods()
            pod_phase = pods[0]['status']['phase']
            if pod_phase != 'Pending':
                return
            time.sleep(API_CHECK_DELAY_SECONDS)
        self.log.debug(pods[0]['status'])
        self.cleanup()
        raise exceptions.AnsibleTestError('Could not start pod associated with job')
def wait_on_pod_ready ( self ) : self . log . info ( 'Creating pod...' ) for i in range ( API_CHECK_RETRIES ) : pods = self . get_pods ( ) if len ( pods ) < 1 : time . sleep ( API_CHECK_DELAY_SECONDS ) continue break if len ( pods ) < 1 : self . cleanup ( ) raise exceptions . AnsibleTestError ( 'Could not create pod associated with job' ) self . log . info ( 'Scheduling pod and waiting until it is running...' ) for i in range ( API_CHECK_RETRIES ) : pods = self . get_pods ( ) pod_phase = pods [ 0 ] [ 'status' ] [ 'phase' ] if pod_phase != 'Pending' : return time . sleep ( API_CHECK_DELAY_SECONDS ) self . log . debug ( pods [ 0 ] [ 'status' ] ) self . cleanup ( ) raise exceptions . AnsibleTestError ( 'Could not start pod associated with job' )
Wait until job's pod initializes, pulls image, and starts running.
Wait until job ' s pod initializes pulls image and starts running .
"""Wait until job's pod initializes, pulls image, and starts running."""
self