6 DEFAULT_SOCKET_PATH="/var/spool/orchestra/conductor.sock"
8 class ServerError(Exception):
11 def submit_job(score, scope, target, args=None, sockname=DEFAULT_SOCKET_PATH):
20 reqObj['players'] = list(target)
23 reqObj['params'] = args
25 sock = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
26 sock.connect(sockname)
29 f.write(json.dumps(reqObj))
36 raise ServerError(resp[1])
40 def get_status(jobid, sockname=DEFAULT_SOCKET_PATH):
45 sock = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
46 sock.connect(sockname)
49 f.write(json.dumps(reqObj))
56 raise ServerError(resp[1])