def _poll_event()

in getting_started/utils/lookout_equipment_utils.py [0:0]

• 11 lines of code
• 2 McCabe index (conditional complexity)

    def _poll_event(self, scheduler_status, wait_state, sleep_time=5):
        """
        Wait for a given scheduler update process to be finished
        
        PARAMS
        ======
            scheduler_status: string
                Initial scheduler status
            
            wait_state: string (either PENDING, STOPPING)
                The wait will continue while the status has a value equal
                to this wait_state string
                
            sleep_time: integer (default: 5)
                How many seconds should we wait before polling again
        """
        print("===== Polling Inference Scheduler Status =====\n")
        print("Scheduler Status: " + scheduler_status)
        while scheduler_status == wait_state:
            time.sleep(sleep_time)
            describe_scheduler_response = self.client.describe_inference_scheduler(
                InferenceSchedulerName=self.scheduler_name
            )
            scheduler_status = describe_scheduler_response['Status']
            print("Scheduler Status: " + scheduler_status)
        print("\n===== End of Polling Inference Scheduler Status =====")