The rate limits can be specified in seconds, minutes or hours by appending “/s”, “/m” or “/h” to the value. Example: “100/m” (hundred tasks a minute). Default is the CELERY_DEFAULT_RATE_LIMIT setting, which broadcast >>> broadcast("rate_limit", arguments={"task_name": "myapp.mytask", ... "rate_limit": "200/m"}) This will send the command asynchronously, without waiting for a reply. To request a reply you have the reply argument: >>> broadcast("rate_limit", {"task_name": "myapp.mytask", ... "rate_limit": "200/m"}, reply=True) [{’worker1.example.com’: ’New rate limit set successfully’}, {’worker2.example.com’:

The rate limits can be specified in seconds, minutes or hours by appending “/s”, “/m” or “/h” to the value. Example: “100/m” (hundred tasks a minute). Default is the CELERY_DEFAULT_RATE_LIMIT setting, which broadcast >>> broadcast("rate_limit", arguments={"task_name": "myapp.mytask", ... "rate_limit": "200/m"}) This will send the command asynchronously, without waiting for a reply. To request a reply you have the reply argument: >>> broadcast("rate_limit", {"task_name": "myapp.mytask", ... "rate_limit": "200/m"}, reply=True) [{’worker1.example.com’: ’New rate limit set successfully’}, {’worker2.example.com’:

The rate limits can be specified in seconds, minutes or hours by appending “/s”, “/m” or “/h” to the value. Example: “100/m” (hundred tasks a minute). Default is the CELERY_DEFAULT_RATE_LIMIT setting, which broadcast >>> broadcast("rate_limit", arguments={"task_name": "myapp.mytask", ... "rate_limit": "200/m"}) This will send the command asynchronously, without waiting for a reply. To request a reply you have Documentation, Release 2.5.5 >>> broadcast("rate_limit", {"task_name": "myapp.mytask", ... "rate_limit": "200/m"}, reply=True) [{’worker1.example.com’: ’New rate limit set successfully’}, {’worker2.example.com’:

The rate limits can be specified in seconds, minutes or hours by appending “/s”, “/m” or “/h” to the value. Example: “100/m” (hundred tasks a minute). Default is the CELERY_DEFAULT_RATE_LIMIT setting, which arguments={"task_name": "myapp.mytask", ... "rate_limit": "200/m"}) This will send the command asynchronously, without waiting for a reply. To request a reply you have broadcast("rate_limit", {"task_name": "myapp.mytask", ... "rate_limit": "200/m"}, reply=True) [{'worker1.example.com': 'New rate limit set successfully'}, {'worker2.example.com':

The rate limits can be specified in seconds, minutes or hours by appending “/s”, “/m” or “/h” to the value. Example: “100/m” (hundred tasks a minute). Default is the CELERY_DEFAULT_RATE_LIMIT setting, which arguments={"task_name": "myapp.mytask", ... "rate_limit": "200/m"}) This will send the command asynchronously, without waiting for a reply. To request a reply you have broadcast("rate_limit", {"task_name": "myapp.mytask", ... "rate_limit": "200/m"}, reply=True) [{'worker1.example.com': 'New rate limit set successfully'}, {'worker2.example.com':

the current stable version of Celery (4.4). For development docs, go here. Copyright Celery User Manual by Ask Solem Copyright © 2009-2016, Ask Solem. All rights reserved. This material may be copied configuration file works properly and doesn’t contain any syntax errors, you can try to import it: $ python -m celeryconfig For a complete reference of configuration options, see Configuration and defaults. To 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 or Redis as the broker then you

the current stable version of Celery (4.4). For development docs, go here. Copyright Celery User Manual by Ask Solem Copyright © 2009-2016, Ask Solem. All rights reserved. This material may be copied configuration file works properly and doesn’t contain any syntax errors, you can try to import it: $ python -m celeryconfig For a complete reference of configuration options, see Configuration and defaults. To 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 or Redis as the broker then you

the current stable version of Celery (4.4). For development docs, go here. Copyright Celery User Manual by Ask Solem Copyright © 2009-2016, Ask Solem. All rights reserved. This material may be copied configuration file works properly and doesn’t contain any syntax errors, you can try to import it: $ python -m celeryconfig For a complete reference of configuration options, see Configuration and defaults. To 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 or Redis as the broker then you

the current stable version of Celery (4.4). For development docs, go here. Copyright Celery User Manual by Ask Solem Copyright © 2009-2016, Ask Solem. All rights reserved. This material may be copied configuration file works properly and doesn’t contain any syntax errors, you can try to import it: $ python -m celeryconfig For a complete reference of configuration options, see Configuration and defaults. To 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 or Redis as the broker then you

the current stable version of Celery (4.4). For development docs, go here. Copyright Celery User Manual by Ask Solem Copyright © 2009-2016, Ask Solem. All rights reserved. This material may be copied configuration file works properly and doesn’t contain any syntax errors, you can try to import it: $ python -m celeryconfig For a complete reference of configuration options, see Configuration and defaults. To 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 or Redis as the broker then you