View of /ea/job_submission.py

#
# BonFIRE Virtual Clusters on Federated Clouds Demonstration Kit
#
# Copyright (c) Fundacion Centro Tecnologico de Supercomputacion de Galicia 2012
# 
# License GPL Version 3
#
# The research leading to these results has received funding from 
# the European Community's Seventh Frameqork Programme (FP7/2007-2013) 
# under agreement number 257386
#
# This software is provided with ABSOLUTELY NO WARRANTY
# 
'''
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