import time

print "--SELFTEST-- loading test"

us = [ '127.0.0.1#P1', '127.0.0.1#P2' ]

def payload1():
	print "--STEPTEST-- payload1 start"

	b = job.barrier('127.0.0.1#P1', 'here', 45)
	b.rendevous(*us)

	print "--STEPTEST-- payload1 complete"

def payload2():
	print "--STEPTEST-- payload2 start"

	time.sleep(5)
	b = job.barrier('127.0.0.1#P2', 'here', 40)
	b.rendevous(*us)

	time.sleep(1)
	print "--STEPTEST-- payload2 complete"

job.parallel([payload1], [payload2])