CELERY_QUEUES = Queue('important', exchange=Exchange('important'),
    routing_key='important', queue_arguments={'x-max-length': 10}),
Сельдерей: как ограничить количество задач в очереди и прекратить подачу при заполнении?