[bonfiredemokit] View of /ea/job_submission.py
View of /ea/job_submission.py
Parent Directory
| Revision Log
Revision 1 -
( download)
( as text)
( annotate)
Mon Aug 27 11:46:35 2012 UTC
(11 years, 10 months ago)
by agomez
File size: 703 byte(s)
'''
Created on 01/03/2012
@author: R. Valin
'''
import saga
try:
# create an "echo 'hello, world' job"
jd = saga.job.description()
jd.set_attribute("Executable", "/bin/echo")
jd.set_vector_attribute("Arguments", ["Hello, World!"])
jd.set_attribute("Interactive", "True")
# connect to the local job service
js = saga.job.service("fork://localhost");
# submit the job
job = js.create_job(jd)
job.run()
# wait for the job to complete
job.wait(-1)
# print the job's output
output = job.get_stdout()
print output.read()
except saga.exception, e:
print "ERROR: "
for err in e.get_all_messages():
print err
|