FastQueue(maxsize=0) Queue.Queue supporting the interface of TokenBucketQueue. clear() expected_time(tokens=1) items wait(block=True) exception celery.worker.buckets.RateLimitExceeded The token buckets from the first available bucket. Available as in, there is an item in the queue and you can consume tokens from it. get_bucket_for_type(task_name) Get the bucket for a particular task type. get_nowait() on get operations. Parameters • fill_rate – The rate in tokens/second that the bucket will be refilled. • capacity – Maximum number of tokens in the bucket. Default is 1. exception RateLimitExceeded

FastQueue(maxsize=0) Queue.Queue supporting the interface of TokenBucketQueue. clear() expected_time(tokens=1) items wait(block=True) exception celery.worker.buckets.RateLimitExceeded The token buckets from the first available bucket. Available as in, there is an item in the queue and you can consume tokens from it. get_bucket_for_type(task_name) Get the bucket for a particular task type. get_nowait() on get operations. Parameters • fill_rate – The rate in tokens/second that the bucket will be refilled. • capacity – Maximum number of tokens in the bucket. Default is 1. exception RateLimitExceeded

FastQueue(maxsize=0) Queue.Queue supporting the interface of TokenBucketQueue. clear() expected_time(tokens=1) items wait(block=True) exception celery.worker.buckets.RateLimitExceeded The token buckets from the first available bucket. Available as in, there is an item in the queue and you can consume tokens from it. get_bucket_for_type(task_name) Get the bucket for a particular task type. get_nowait() on get operations. Parameters • fill_rate – The rate in tokens/second that the bucket will be refilled. • capacity – Maximum number of tokens in the bucket. Default is 1. exception RateLimitExceeded

FastQueue(maxsize=0) Queue.Queue supporting the interface of TokenBucketQueue. clear() expected_time(tokens=1) items wait(block=True) exception celery.worker.buckets.RateLimitExceeded The token buckets from the first available bucket. Available as in, there is an item in the queue and you can consume tokens from it. get_bucket_for_type(task_name) Get the bucket for a particular task type. get_nowait() queue on get operations. Parameters: fill_rate – The rate in tokens/second that the bucket will be refilled. capacity – Maximum number of tokens in the bucket. Default is 1. exception RateLimitExceeded

FastQueue(maxsize=0) Queue.Queue supporting the interface of TokenBucketQueue. clear() expected_time(tokens=1) items wait(block=True) exception celery.worker.buckets.RateLimitExceeded The token buckets from the first available bucket. Available as in, there is an item in the queue and you can consume tokens from it. get_bucket_for_type(task_name) Get the bucket for a particular task type. get_nowait() queue on get operations. Parameters: fill_rate – The rate in tokens/second that the bucket will be refilled. capacity – Maximum number of tokens in the bucket. Default is 1. exception RateLimitExceeded

FastQueue(maxsize=0) Queue.Queue supporting the interface of TokenBucketQueue. clear() expected_time(tokens=1) items wait(block=True) exception celery.worker.buckets.RateLimitExceeded The token buckets from the first available bucket. Available as in, there is an item in the queue and you can consume tokens from it. get_bucket_for_type(task_name) Get the bucket for a particular task type. get_nowait() queue on get operations. Parameters: fill_rate – The rate in tokens/second that the bucket will be refilled. capacity – Maximum number of tokens in the bucket. Default is 1. exception RateLimitExceeded

FastQueue(maxsize=0) Queue.Queue supporting the interface of TokenBucketQueue. clear() expected_time(tokens=1) items wait(block=True) exception celery.worker.buckets.RateLimitExceeded The token buckets from the first available bucket. Available as in, there is an item in the queue and you can consume tokens from it. get_bucket_for_type(task_name) Get the bucket for a particular task type. get_nowait() on get operations. Parameters • fill_rate – The rate in tokens/second that the bucket will be refilled. • capacity – Maximum number of tokens in the bucket. Default is 1. exception RateLimitExceeded

FastQueue(maxsize=0) Queue.Queue supporting the interface of TokenBucketQueue. clear() expected_time(tokens=1) items wait(block=True) exception celery.worker.buckets.RateLimitExceeded The token buckets from the first available bucket. Available as in, there is an item in the queue and you can consume tokens from it. get_bucket_for_type(task_name) Get the bucket for a particular task type. get_nowait() queue on get operations. Parameters: fill_rate – The rate in tokens/second that the bucket will be refilled. capacity – Maximum number of tokens in the bucket. Default is 1. exception RateLimitExceeded

roles on instances, you can set the BROKER_URL to: sqs:// and kombu will attempt to retrieve access tokens from the instance metadata. Options Region The default region is us-east-1 but you can select mbu.utils.limits.html#kombu.utils.limits.TokenBucket] instance implementing consume(tokens) and expected_time(tokens). TokenBucket implements the token bucket algorithm [https://en.wikipedia.org/wiki/Token_bucket] verify the information before submitting so that it doesn’t contain confidential information like API tokens and authentication credentials. E. Your issue might be tagged as Needs Test Case. A test case represents

roles on instances, you can set the BROKER_URL to: sqs:// and kombu will attempt to retrieve access tokens from the instance metadata. Options Region The default region is us-east-1 but you can select mbu.utils.limits.html#kombu.utils.limits.TokenBucket] instance implementing consume(tokens) and expected_time(tokens). TokenBucket implements the token bucket algorithm [https://en.wikipedia.org/wiki/Token_bucket] verify the information before submitting so that it doesn’t contain confidential information like API tokens and authentication credentials. E. Your issue might be tagged as Needs Test Case. A test case represents