diff --git a/src/execo_g5k/oar.py b/src/execo_g5k/oar.py index e8bba10785e71a5fff3f2cca2f56fbaa34068870..dc9c6781dfdd7c462e78b17ed0d35b50b1d77eff 100644 --- a/src/execo_g5k/oar.py +++ b/src/execo_g5k/oar.py @@ -210,9 +210,8 @@ def get_oarsub_commandline(job_spec): key = os.environ.get('OAR_JOB_KEY_FILE') if key != None: oarsub_cmdline += ' -k -i %s' % (key,) - if job_spec.job_type != None: - for t in singleton_to_collection(job_spec.job_type): - oarsub_cmdline += ' -t "%s"' % (t,) + for t in set(singleton_to_collection(job_spec.job_type) + [ 'origin=execo' ]): + oarsub_cmdline += ' -t "%s"' % (t,) if job_spec.sql_properties != None: oarsub_cmdline += ' -p "%s"' % (job_spec.sql_properties,) if job_spec.queue != None: