#NEWLINE# def wait_for_job( manager , job_config , poll_time = DEFAULT_POLL_TIME ) : #NEWLINE# #INDENT# job_id = job_config . get ( 'job_id' ) #NEWLINE# while True : #NEWLINE# #INDENT# status = manager . get_status ( job_id ) #NEWLINE# if is_job_done ( status ) : #NEWLINE# #INDENT# break #NEWLINE# #UNINDENT# time . sleep ( poll_time )