From eae1bcf28315e786367a17975710742dd501b644 Mon Sep 17 00:00:00 2001 From: ilan Date: Wed, 5 Apr 2017 13:12:17 +0300 Subject: [PATCH] Checks if SQS is retrying in time --- django_q/tests/test_brokers.py | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) diff --git a/django_q/tests/test_brokers.py b/django_q/tests/test_brokers.py index a719c49..bf8e518 100644 --- a/django_q/tests/test_brokers.py +++ b/django_q/tests/test_brokers.py @@ -190,10 +190,13 @@ def test_sqs(monkeypatch): monkeypatch.setattr(Conf, 'RETRY', 1) broker.enqueue('test') sleep(2) - task = broker.dequeue()[0] - assert len(task) > 0 - broker.acknowledge(task[0]) - sleep(2) + # Sometimes SQS is not linear + task = broker.dequeue() + if task: + task = task[0] + assert len(task) > 0 + broker.acknowledge(task[0]) + sleep(2) # delete job broker.enqueue('test') task_id = broker.dequeue()[0][0]