1 import time 2 3 print "--SELFTEST-- loading test" 4 5 def payload1(): 6 print "--STEPTEST-- payload1 start" 7 sys.stdout.flush() 8 time.sleep(2) 9 print "--STEPTEST-- payload1 complete" 10 sys.stdout.flush() 11 12 def 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 20 job.parallel([payload1], [payload2]) 21
