How to use the pyqs.worker.MESSAGE_DOWNLOAD_BATCH_SIZE function in pyqs
To help you get started, we’ve selected a few pyqs examples, based on popular ways it is used in public projects.
Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
spulec / PyQS / tests / test_worker.py View on Github 
def test_worker_to_large_batch_size():
"""
Test workers with too large of a batch size
"""
BATCHSIZE = 10000
CONCURRENCY = 1
QUEUE_PREFIX = "tester"
INTERVAL = 0.0
conn = boto3.client('sqs', region_name='us-east-1')
conn.create_queue(QueueName="tester")['QueueUrl']
worker = ManagerWorker(QUEUE_PREFIX, CONCURRENCY, INTERVAL, BATCHSIZE)
worker.batchsize.should.equal(MESSAGE_DOWNLOAD_BATCH_SIZE)
Popular pyqs functions
- pyqs.__version__
- pyqs.main._main
- pyqs.main.main
- pyqs.task
- pyqs.utils.decode_message
- pyqs.utils.function_to_import_path
- pyqs.utils.get_aws_region_name
- pyqs.worker._main
- pyqs.worker.BaseWorker
- pyqs.worker.ManagerWorker
- pyqs.worker.ManagerWorker.return_value.start.assert_called_once_with
- pyqs.worker.MESSAGE_DOWNLOAD_BATCH_SIZE
- pyqs.worker.ProcessWorker
- pyqs.worker.ReadWorker