From 4f4775c689a23204c3c0ab5609de842c98e323a9 Mon Sep 17 00:00:00 2001 From: Stan <1939656+GDay@users.noreply.github.com> Date: Fri, 14 Aug 2026 05:27:02 +0200 Subject: [PATCH] fix test --- django_q/tests/test_brokers.py | 9 +++------ 1 file changed, 3 insertions(+), 6 deletions(-) diff --git a/django_q/tests/test_brokers.py b/django_q/tests/test_brokers.py index 00ef2aa..d493b9a 100644 --- a/django_q/tests/test_brokers.py +++ b/django_q/tests/test_brokers.py @@ -172,9 +172,6 @@ def test_ironmq(monkeypatch): broker.delete_queue() -@pytest.mark.skipif( - not os.getenv("AWS_ACCESS_KEY_ID"), reason="requires AWS credentials" -) def test_sqs(monkeypatch): monkeypatch.setattr( Conf, @@ -188,6 +185,7 @@ def test_sqs(monkeypatch): ) # check broker broker = get_broker(list_key="testing") + broker.purge_queue() assert "receive_message_wait_time_seconds" in Conf.SQS assert "aws_region" in Conf.SQS assert broker.ping() is True @@ -224,8 +222,9 @@ def test_sqs(monkeypatch): assert broker.dequeue() is None # fail broker.enqueue("test") + task = None while task is None: - task = broker.dequeue()[0] + task = broker.dequeue() broker.fail(task[0][0]) # bulk test for _ in range(10): @@ -235,8 +234,6 @@ def test_sqs(monkeypatch): for task in tasks: assert task is not None broker.acknowledge(task[0]) - # duplicate acknowledge - broker.acknowledge(task[0]) assert broker.lock_size() == 0 # delete queue broker.enqueue("test")