class Config(object):
    BROKER_URL = 'amqp://guest@localhost//'
CELERY_QUEUES = Queue('important', exchange=Exchange('important'),
    routing_key='important', queue_arguments={'x-max-length': 10}),
app = Celery('tasks')
app.config_from_object(Config)
Сельдерей: как ограничить количество задач в очереди и прекратить подачу при заполнении?