1import time 2 3print "--SELFTEST-- loading test" 4 5us = [ '127.0.0.1#P1', '127.0.0.1#P2' ] 6 7def payload1(): 8 print "--STEPTEST-- payload1 start" 9 10 b = job.barrier('127.0.0.1#P2', 'here', 45) 11 b.rendezvous(*us) 12 13 print "--STEPTEST-- payload1 complete" 14 15def payload2(): 16 print "--STEPTEST-- payload2 start" 17 18 time.sleep(5) 19 b = job.barrier('127.0.0.1#P1', 'here', 40) 20 b.rendezvous(*us) 21 22 time.sleep(1) 23 print "--STEPTEST-- payload2 complete" 24 25job.parallel([payload1], [payload2]) 26