Checks if SQS is retrying in time

This commit is contained in:
ilan
2017-04-05 13:12:17 +03:00
parent 8c6058003f
commit eae1bcf283
+4 -1
View File
@@ -190,7 +190,10 @@ def test_sqs(monkeypatch):
monkeypatch.setattr(Conf, 'RETRY', 1)
broker.enqueue('test')
sleep(2)
task = broker.dequeue()[0]
# Sometimes SQS is not linear
task = broker.dequeue()
if task:
task = task[0]
assert len(task) > 0
broker.acknowledge(task[0])
sleep(2)