1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
|
#!/usr/bin/env python3
import sys
import yaml
#import xmlrpclib
import xmlrpc.client
import configparser
configfile = "post.conf"
def get_cfg_value(configfile, category, what, strict = 'yes'):
ret = None
parser = configparser.SafeConfigParser()
parser.read(configfile)
try:
ret = parser.get(category, what)
except:
print('No option %s= found in config file. Fix your config file' % what)
if strict == 'yes':
exit(1);
return ret
def submit_yaml_job(job_yaml_str, user, token, host):
server = xmlrpc.client.ServerProxy("https://%s:%s@%s/RPC2" % (user, token,
host))
try:
job_id = server.scheduler.submit_job(job_yaml_str)
#print "Job submitted successfuly"
except:
raise
def main():
if len(sys.argv) < 1:
print ("""usage: submit_job.py JOB_YAML""")
exit(1)
with open(sys.argv[1], 'r') as stream:
job_yaml = stream.read()
user = get_cfg_value(configfile, 'auth', 'user')
token = get_cfg_value(configfile, 'auth', 'token')
host = get_cfg_value(configfile, 'auth', 'host')
submit_yaml_job(job_yaml, user, token, host)
if __name__ == "__main__":
main()
|