cyme.branch.managers

cyme.branch.managers

• Contains the LocalInstanceManager instance, which is the preferred API used to control and manage worker instances handled by this branch. I.e. it can be used to do synchronous actions that don’t return until the supervisor has performed them.

class cyme.branch.managers.LocalInstanceManager

Brokers = <cyme.models.managers.BrokerManager object at 0x3f91090>

Instances = <cyme.models.managers.InstanceManager object at 0x3f92350>

add(name=None, queues=None, max_concurrency=1, min_concurrency=1, broker=None, pool=None, app=None, arguments=None, extra_config=None, nowait=False, **kwargs)

add_consumer(name, queue, nowait=False)

cancel_consumer(name, queue, nowait=False)

disable(name, nowait=False)

enable(name, nowait=False)

get(name)

maybe_wait(fun, instances, nowait)

remove(name, nowait=False)

remove_queue(queue, nowait=False)

restart(name, nowait=False)