- import subprocess
- import sys
- worker = "e1_worker.sh"
- if len(sys.argv) == 3:
- worker = sys.argv[2]
- for i in range(int(sys.argv[1])):
- print 'submitting job %s' % i
- proc = subprocess.Popen(['bsub'], stdin=subprocess.PIPE)
- proc.communicate(open(worker).read())
|
