fork/django-q2
1
0
Fork 0
mirror of https://github.com/django-q2/django-q2.git synced 2026-10-08 22:18:13 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix test

Browse Source
This commit is contained in:
Stan
2026-08-14 05:27:02 +02:00
parent fde502d8a0
commit 4f4775c689
1 changed files with 3 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
django_q/tests/test_brokers.py
+3 -6
View File
@@ -172,9 +172,6 @@ def test_ironmq(monkeypatch):
broker.delete_queue() broker.delete_queue()
@pytest.mark.skipif(
not os.getenv("AWS_ACCESS_KEY_ID"), reason="requires AWS credentials"
)
def test_sqs(monkeypatch): def test_sqs(monkeypatch):
monkeypatch.setattr( monkeypatch.setattr(
Conf, Conf,
@@ -188,6 +185,7 @@ def test_sqs(monkeypatch):
) )
# check broker # check broker
broker = get_broker(list_key="testing") broker = get_broker(list_key="testing")
broker.purge_queue()
assert "receive_message_wait_time_seconds" in Conf.SQS assert "receive_message_wait_time_seconds" in Conf.SQS
assert "aws_region" in Conf.SQS assert "aws_region" in Conf.SQS
assert broker.ping() is True assert broker.ping() is True
@@ -224,8 +222,9 @@ def test_sqs(monkeypatch):
assert broker.dequeue() is None assert broker.dequeue() is None
# fail # fail
broker.enqueue("test") broker.enqueue("test")
task = None
while task is None: while task is None:
task = broker.dequeue()[0] task = broker.dequeue()
broker.fail(task[0][0]) broker.fail(task[0][0])
# bulk test # bulk test
for _ in range(10): for _ in range(10):
@@ -235,8 +234,6 @@ def test_sqs(monkeypatch):
for task in tasks: for task in tasks:
assert task is not None assert task is not None
broker.acknowledge(task[0]) broker.acknowledge(task[0])
# duplicate acknowledge
broker.acknowledge(task[0])
assert broker.lock_size() == 0 assert broker.lock_size() == 0
# delete queue # delete queue
broker.enqueue("test") broker.enqueue("test")