Redis, and MongoDB transports. celery control [OPTIONS] [revoke|terminate|rate_limit|time_limit|election|enab Options: le_events|disable_events|heartbeat|pool_grow|pool_shrink|pool_r pool. the number of tasks discarded. int [https://docs.python.org/dev/library/functions.html#int] election(id, topic, action=None, connection=None)[source] enable_events(destination=None, **kwargs)[source] call_task(task)[source] compatible_transport(app)[source] compatible_transports = {'amqp', 'redis'} election(id, topic, action=None)[source] get_consumers(channel)[source] label = 'Gossip' name = 'celery

Redis, and MongoDB transports. celery control [OPTIONS] [revoke|terminate|rate_limit|time_limit|election|enab Options: le_events|disable_events|heartbeat|pool_grow|pool_shrink|pool_r pool. the number of tasks discarded. int [https://docs.python.org/dev/library/functions.html#int] election(id, topic, action=None, connection=None)[source] enable_events(destination=None, **kwargs)[source] call_task(task)[source] compatible_transport(app)[source] compatible_transports = {'amqp', 'redis'} election(id, topic, action=None)[source] get_consumers(channel)[source] label = 'Gossip' name = 'celery

Redis, and MongoDB transports. celery control [OPTIONS] [revoke|terminate|rate_limit|time_limit|election|enab Options: le_events|disable_events|heartbeat|pool_grow|pool_shrink|pool_r pool. the number of tasks discarded. int [https://docs.python.org/dev/library/functions.html#int] election(id, topic, action=None, connection=None)[source] enable_events(destination=None, **kwargs)[source] call_task(task)[source] compatible_transport(app)[source] compatible_transports = {'amqp', 'redis'} election(id, topic, action=None)[source] get_consumers(channel)[source] label = 'Gossip' name = 'celery

Redis, and MongoDB transports. celery control [OPTIONS] [revoke|terminate|rate_limit|time_limit|election|enab Options: le_events|disable_events|heartbeat|pool_grow|pool_shrink|pool_r pool. the number of tasks discarded. int [https://docs.python.org/dev/library/functions.html#int] election(id, topic, action=None, connection=None)[source] enable_events(destination=None, **kwargs)[source] call_task(task)[source] compatible_transport(app)[source] compatible_transports = {'amqp', 'redis'} election(id, topic, action=None)[source] get_consumers(channel)[source] label = 'Gossip' name = 'celery

acquired from the connection pool. Returns: the number of tasks discarded. Return type: int Control.election(id, topic, action=None, connection=None)[source] Control.enable_events(destination=None, **kwargs)[source] call_task(task)[source] compatible_transport(app)[source] compatible_transports = set([u'redis', u'amqp']) election(id, topic, action=None)[source] get_consumers(channel)[source] label = u'Gossip' name = u'celery call_task(task)[source] compatible_transport(app)[source] compatible_transports = set([u'redis', u'amqp']) election(id, topic, action=None)[source] get_consumers(channel)[source] label = u'Gossip' name = u'celery

acquired from the connection pool. Returns: the number of tasks discarded. Return type: int Control.election(id, topic, action=None, connection=None)[source] Control.enable_events(destination=None, **kwargs)[source] call_task(task)[source] compatible_transport(app)[source] compatible_transports = set([u'redis', u'amqp']) election(id, topic, action=None)[source] get_consumers(channel)[source] label = u'Gossip' name = u'celery call_task(task)[source] compatible_transport(app)[source] compatible_transports = set([u'redis', u'amqp']) election(id, topic, action=None)[source] get_consumers(channel)[source] label = u'Gossip' name = u'celery

acquired from the connection pool. Returns the number of tasks discarded. Return type int Control.election(id, topic, action=None, connection=None) Control.enable_events(destination=None, **kwargs) Tell call_task(task) compatible_transport(app) compatible_transports = set([u’redis’, u’amqp’]) election(id, topic, action=None) get_consumers(channel) label = u’Gossip’ name = u’celery.worker.consumer call_task(task) compatible_transport(app) compatible_transports = set([u’redis’, u’amqp’]) election(id, topic, action=None) get_consumers(channel) label = u’Gossip’ name = u’celery.worker.consumer

acquired from the connection pool. Returns the number of tasks discarded. Return type int Control.election(id, topic, action=None, connection=None) Control.enable_events(destination=None, **kwargs) Tell call_task(task) compatible_transport(app) compatible_transports = set([u’redis’, u’amqp’]) election(id, topic, action=None) get_consumers(channel) label = u’Gossip’ name = u’celery.worker.consumer call_task(task) compatible_transport(app) compatible_transports = set([u’redis’, u’amqp’]) election(id, topic, action=None) 396 Chapter 2. Contents Celery Documentation, Release 4.1.0 get_consumers(channel)

acquired from the connection pool. Returns the number of tasks discarded. Return type int Control.election(id, topic, action=None, connection=None) Control.enable_events(destination=None, **kwargs) Tell call_task(task) compatible_transport(app) compatible_transports = set([u’redis’, u’amqp’]) election(id, topic, action=None) get_consumers(channel) label = u’Gossip’ name = u’celery.worker.consumer call_task(task) compatible_transport(app) compatible_transports = set([u’redis’, u’amqp’]) election(id, topic, action=None) get_consumers(channel) label = u’Gossip’ name = u’celery.worker.consumer

acquired from the connection pool. Returns the number of tasks discarded. Return type int Control.election(id, topic, action=None, connection=None) Control.enable_events(destination=None, **kwargs) Tell call_task(task) compatible_transport(app) compatible_transports = set([u’redis’, u’amqp’]) election(id, topic, action=None) get_consumers(channel) label = u’Gossip’ name = u’celery.worker.consumer call_task(task) compatible_transport(app) compatible_transports = set([u’redis’, u’amqp’]) election(id, topic, action=None) get_consumers(channel) label = u’Gossip’ 388 Chapter 2. Contents Celery