"SASL CXC 138 11","2.1.8"}, {stdlib,"ERTS CXC 138 10","1.16.4"}, {kernel,"ERTS CXC 138 10","2.13.4"}]}, {nodes,[rabbit@myhost]}, {running_nodes,[rabbit@myhost]}] aws.amazon.com/AWSSimpleQueueService/latest/APIReference/API_ReceiveMessage.html] operation is set to 10 seconds. The value of WaitTimeSeconds parameter can be set via the broker_transport_options setting: limit the task instead, so that only 10 tasks of this type can be processed in a minute (10/m): celeryconfig.py: task_annotations = { 'tasks.add': {'rate_limit': '10/m'} } If you’re using RabbitMQ

"SASL CXC 138 11","2.1.8"}, {stdlib,"ERTS CXC 138 10","1.16.4"}, {kernel,"ERTS CXC 138 10","2.13.4"}]}, {nodes,[rabbit@myhost]}, {running_nodes,[rabbit@myhost]}] aws.amazon.com/AWSSimpleQueueService/latest/APIReference/API_ReceiveMessage.html] operation is set to 10 seconds. The value of WaitTimeSeconds parameter can be set via the broker_transport_options setting: limit the task instead, so that only 10 tasks of this type can be processed in a minute (10/m): celeryconfig.py: task_annotations = { 'tasks.add': {'rate_limit': '10/m'} } If you’re using RabbitMQ

"SASL CXC 138 11","2.1.8"}, {stdlib,"ERTS CXC 138 10","1.16.4"}, {kernel,"ERTS CXC 138 10","2.13.4"}]}, {nodes,[rabbit@myhost]}, {running_nodes,[rabbit@myhost]}] aws.amazon.com/AWSSimpleQueueService/latest/APIReference/API_ReceiveMessage.html] operation is set to 10 seconds. The value of WaitTimeSeconds parameter can be set via the broker_transport_options setting: limit the task instead, so that only 10 tasks of this type can be processed in a minute (10/m): celeryconfig.py: task_annotations = { 'tasks.add': {'rate_limit': '10/m'} } If you’re using RabbitMQ

"SASL CXC 138 11","2.1.8"}, {stdlib,"ERTS CXC 138 10","1.16.4"}, {kernel,"ERTS CXC 138 10","2.13.4"}]}, {nodes,[rabbit@myhost]}, {running_nodes,[rabbit@myhost]}] aws.amazon.com/AWSSimpleQueueService/latest/APIReference/API_ReceiveMessage.html] operation is set to 10 seconds. The value of WaitTimeSeconds parameter can be set via the broker_transport_options setting: limit the task instead, so that only 10 tasks of this type can be processed in a minute (10/m): celeryconfig.py: task_annotations = { 'tasks.add': {'rate_limit': '10/m'} } If you’re using RabbitMQ

"SASL CXC 138 11","2.1.8"}, {stdlib,"ERTS CXC 138 10","1.16.4"}, {kernel,"ERTS CXC 138 10","2.13.4"}]}, {nodes,[rabbit@myhost]}, {running_nodes,[rabbit@myhost]}] limit the task instead, so that only 10 tasks of this type can be processed in a minute (10/m): celeryconfig.py: task_annotations = { 'tasks.add': {'rate_limit': '10/m'} } If you’re using RabbitMQ workers to set a new rate limit for the task at runtime: $ celery -A tasks control rate_limit tasks.add 10/m worker@example.com: OK new rate limit set successfully See Routing Tasks to read more about

"SASL CXC 138 11","2.1.8"}, {stdlib,"ERTS CXC 138 10","1.16.4"}, {kernel,"ERTS CXC 138 10","2.13.4"}]}, {nodes,[rabbit@myhost]}, {running_nodes,[rabbit@myhost]}] limit the task instead, so that only 10 tasks of this type can be processed in a minute (10/m): celeryconfig.py: task_annotations = { 'tasks.add': {'rate_limit': '10/m'} } If you’re using RabbitMQ workers to set a new rate limit for the task at runtime: $ celery -A tasks control rate_limit tasks.add 10/m worker@example.com: OK new rate limit set successfully See Routing Tasks to read more about

"SASL CXC 138 11","2.1.8"}, {stdlib,"ERTS CXC 138 10","1.16.4"}, {kernel,"ERTS CXC 138 10","2.13.4"}]}, {nodes,[rabbit@myhost]}, {running_nodes,[rabbit@myhost]}] aws.amazon.com/AWSSimpleQueueService/latest/APIReference/API_ReceiveMessage.html] operation is set to 10 seconds. The value of WaitTimeSeconds parameter can be set via the broker_transport_options setting: limit the task instead, so that only 10 tasks of this type can be processed in a minute (10/m): celeryconfig.py: task_annotations = { 'tasks.add': {'rate_limit': '10/m'} } If you’re using RabbitMQ

"SASL CXC 138 11","2.1.8"}, {stdlib,"ERTS CXC 138 10","1.16.4"}, {kernel,"ERTS CXC 138 10","2.13.4"}]}, {nodes,[rabbit@myhost]}, {running_nodes,[rabbit@myhost]}] aws.amazon.com/AWSSimpleQueueService/latest/APIReference/API_ReceiveMessage.html] operation is set to 10 seconds. The value of WaitTimeSeconds parameter can be set via the broker_transport_options setting: limit the task instead, so that only 10 tasks of this type can be processed in a minute (10/m): celeryconfig.py: task_annotations = { 'tasks.add': {'rate_limit': '10/m'} } If you’re using RabbitMQ

"SASL CXC 138 11","2.1.8"}, {stdlib,"ERTS CXC 138 10","1.16.4"}, {kernel,"ERTS CXC 138 10","2.13.4"}]}, {nodes,[rabbit@myhost]}, {running_nodes,[rabbit@myhost]}] aws.amazon.com/AWSSimpleQueueService/latest/APIReference/API_ReceiveMessage.html] operation is set to 10 seconds. The value of WaitTimeSeconds parameter can be set via the broker_transport_options setting: limit the task instead, so that only 10 tasks of this type can be processed in a minute (10/m): celeryconfig.py: task_annotations = { 'tasks.add': {'rate_limit': '10/m'} } If you’re using RabbitMQ

"SASL CXC 138 11","2.1.8"}, {stdlib,"ERTS CXC 138 10","1.16.4"}, {kernel,"ERTS CXC 138 10","2.13.4"}]}, {nodes,[rabbit@myhost]}, {running_nodes,[rabbit@myhost]}] aws.amazon.com/AWSSimpleQueueService/latest/APIReference/API_ReceiveMessage.html] operation is set to 10 seconds. The value of WaitTimeSeconds parameter can be set via the broker_transport_options setting: limit the task instead, so that only 10 tasks of this type can be processed in a minute (10/m): celeryconfig.py: task_annotations = { 'tasks.add': {'rate_limit': '10/m'} } If you’re using RabbitMQ