import time print "--SELFTEST-- loading test" def payload1(): print "--STEPTEST-- payload1 start" sys.stdout.flush() time.sleep(2) print "--STEPTEST-- payload1 complete" sys.stdout.flush() def payload2(): time.sleep(1) print "--STEPTEST-- payload2 start" sys.stdout.flush() time.sleep(2) print "--STEPTEST-- payload2 complete" sys.stdout.flush() job.parallel([payload1], [payload2])