def monitor_job_status()

in code/workflow/implementations/autopilot/bp_error_analysis_stage.py [0:0]

• 14 lines of code
• 5 McCabe index (conditional complexity)

def monitor_job_status(job_name, context) :
    
    sleep_time = 60
    while True: 
    
        status = sm.describe_transform_job(TransformJobName = job_name)["TransformJobStatus"]

        if status == 'Completed' : 
            break;
                    
        elif status in ('Failed', 'Stopped') :
            break;
        else :
            
            if context.get_remaining_time_in_millis() > 2000*sleep_time :
                sleep(sleep_time)
            else :
                raise TaskTimedOut("Task timed out.")
    
    return {"status":status}