circus-arbiter-stop-test.py

import circus
from circus import get_arbiter

from tornado import gen

task = {
    "cmd": "ls",
    "args": ["/tmp/test-mount/"]
}

arbiter = get_arbiter(watchers=[task], debug=True)

@gen.coroutine
def stop_arbiter_after_timeout():
    print 'sleeping'
    yield gen.sleep(5)
    print 'stopping arbiter'
    yield arbiter.stop()
    print 'stopped'

def start_arbiter(*args, **kwargs):
    print 'start arbiter'
    arbiter.start(cb=kwargs['callback'])

@gen.coroutine
def run():
    yield [stop_arbiter_after_timeout(), gen.Task(start_arbiter)]

run()

print 'done'