Commit de01a150 authored by Nicolas Wavrant's avatar Nicolas Wavrant

runner: supervisord's library can now stop processes

parent a4a8ad29
...@@ -31,6 +31,17 @@ def runProcesses(config, processes): ...@@ -31,6 +31,17 @@ def runProcesses(config, processes):
waitForProcessEnd(proc) waitForProcessEnd(proc)
def stopProcess(config, process):
server = xmlrpclib.Server(config['supervisord_server'])
server.supervisor.stopProcess(process)
def stopProcesses(config, processes):
server = xmlrpclib.Server(config['supervisord_server'])
for proc in processes:
server.supervisor.stopProcess(proc)
def waitForProcessEnd(config, process): def waitForProcessEnd(config, process):
server = xmlrpclib.Server(config['supervisord_server']) server = xmlrpclib.Server(config['supervisord_server'])
while True: while True:
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment