#NEWLINE# def test_start_job( worker , submit_job ) : #NEWLINE# #INDENT# with Job ( 'JobName' ) as job : #NEWLINE# #INDENT# with Task ( 'TaskName' ) : #NEWLINE# #INDENT# with Task ( 'SubTaskName' ) : #NEWLINE# #INDENT# Action ( msg = 'Action here at $(date).' , _role = 'echo' ) #NEWLINE# #UNINDENT# Action ( msg = 'Action here at $(date).' , _role = 'echo' ) #NEWLINE# #UNINDENT# Action ( msg = 'Action here at $(date).' , _role = 'echo' ) #NEWLINE# #UNINDENT# ( workflow_id , run_id ) = submit_job ( run_id ) #NEWLINE# while ( not is_job_done ( workflow_id , run_id ) ) : #NEWLINE# #INDENT# print ( 'wait' ) #NEWLINE# time . sleep ( 3 ) #NEWLINE# #UNINDENT# assert ( get_close_status ( workflow_id , run_id ) == 'COMPLETED' )