Circus start callback

gistfile1.py

import time

import circus
import redis

from tornado import gen


@gen.coroutine
def start_workers(*args, **kwargs):
    client = redis.Redis()

    # We wait for redis to be up
    while True:
        try:
            client.ping()
        except redis.exceptions.ConnectionError:
            time.sleep(0.05)
        else:
            break

    # We asume that the 'workers' key contains a list of commands
    # to launch
    for i, worker in enumerate(client.lrange('workers', 0, -1)):
        watcher = arbiter.add_watcher(
            'Worker %s' % i,
            worker,
        )
        yield watcher.start()

if __name__ == '__main__':
    arbiter = circus.get_arbiter(
        (
            {'name': 'Redis', 'cmd': 'redis-server'},
        )
    )

    arbiter.start(cb=start_workers)