<s> """<STR_LIT>""" <EOL> import os <EOL> import time <EOL> import pdb <EOL> import sys <EOL> """<STR_LIT>""" <EOL> COORDINATION_URL = "<STR_LIT>" <EOL> sys . path . insert ( <NUM_LIT:0> , os . getcwd ( ) + "<STR_LIT>" ) <EOL> from bigjob import bigjob , subjob , description <EOL> def main ( ) : <EOL> queue = None <EOL> project = None <EOL> walltime = <NUM_LIT:10> <EOL> processes_per_node = <NUM_LIT:8> <EOL> number_nodes = <NUM_LIT> <EOL> workingdirectory = os . getcwd ( ) <EOL> userproxy = None <EOL> """<STR_LIT>""" <EOL> lrms_url = "<STR_LIT>" <EOL> print "<STR_LIT>" + lrms_url <EOL> bj = bigjob ( COORDINATION_URL ) <EOL> bj . start_pilot_job ( lrms_url , <EOL> number_nodes , <EOL> queue , <EOL> project , <EOL> workingdirectory , <EOL> userproxy , <EOL> walltime , <EOL> processes_per_node ) <EOL> print "<STR_LIT>" + bj . pilot_url + "<STR_LIT>" + str ( bj . get_state ( ) ) <EOL> jd = description ( ) <EOL> jd . executable = "<STR_LIT>" <EOL> jd . number_of_processes = "<STR_LIT:2>" <EOL> jd . spmd_variation = "<STR_LIT>" <EOL> jd . arguments = [ "<STR_LIT>" ] <EOL> jd . output = "<STR_LIT>" <EOL> jd . error = "<STR_LIT>" <EOL> for i in range ( <NUM_LIT:0> , <NUM_LIT:12> ) : <EOL> sj = subjob ( ) <EOL> sj . submit_job ( bj . pilot_url , jd ) <EOL> bj . wait ( ) <EOL> bj . cancel ( ) <EOL> """<STR_LIT>""" <EOL> if __name__ == "<STR_LIT:__main__>" : <EOL> main ( ) </s>
