1import time 2 3print "--SELFTEST-- loading test" 4 5def payload1(): 6 print "--STEPTEST-- payload1 start" 7 sys.stdout.flush() 8 time.sleep(2) 9 print "--STEPTEST-- payload1 complete" 10 sys.stdout.flush() 11 12def payload2(): 13 time.sleep(1) 14 print "--STEPTEST-- payload2 start" 15 sys.stdout.flush() 16 time.sleep(2) 17 print "--STEPTEST-- payload2 complete" 18 sys.stdout.flush() 19 20job.parallel([payload1], [payload2]) 21