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

Migrate to Github Action CI (#507)

Browse Source 
* Some small refactors

* Initial test script

* Fixes django matrix

* Trying to set up Disque

* Disque as a docker service

* lowercase action name

* Remove Travis

* Replaces Travis badge with Github actions badge

* Show django version in step

* Typo
This commit is contained in:
Ilan Steemers
2021-02-14 18:59:04 +01:00
committed by GitHub
parent e2580051bc
commit 7d03536e89
12 changed files with 78 additions and 75 deletions
Download Patch File Download Diff File Expand all files Collapse all files
django_q/tests/test_brokers.py
+6 -8
View File
@@ -95,7 +95,7 @@ def test_disque(monkeypatch):
task_id = broker.enqueue("test")
broker.fail(task_id)
# bulk test
for i in range(5):
for _ in range(5):
broker.enqueue("test")
monkeypatch.setattr(Conf, "BULK", 5)
monkeypatch.setattr(Conf, "DISQUE_FASTACK", True)
@@ -166,7 +166,7 @@ def test_ironmq(monkeypatch):
task_id = broker.enqueue("test")
broker.fail(task_id)
# bulk test
for i in range(5):
for _ in range(5):
broker.enqueue("test")
monkeypatch.setattr(Conf, "BULK", 5)
tasks = broker.dequeue()
@@ -236,7 +236,7 @@ def canceled_sqs(monkeypatch):
task = broker.dequeue()[0]
broker.fail(task[0])
# bulk test
for i in range(10):
for _ in range(10):
broker.enqueue("test")
monkeypatch.setattr(Conf, "BULK", 12)
tasks = broker.dequeue()
@@ -290,7 +290,7 @@ def test_orm(monkeypatch):
task_id = broker.enqueue("test")
broker.fail(task_id)
# bulk test
for i in range(5):
for _ in range(5):
broker.enqueue("test")
monkeypatch.setattr(Conf, "BULK", 5)
tasks = broker.dequeue()
@@ -347,11 +347,9 @@ def test_mongo(monkeypatch):
task_id = broker.enqueue("test")
broker.fail(task_id)
# bulk test
for i in range(5):
for _ in range(5):
broker.enqueue("test")
tasks = []
for i in range(5):
tasks.append(broker.dequeue()[0])
tasks = [broker.dequeue()[0] for _ in range(5)]
assert broker.lock_size() == 5
for task in tasks:
assert task is not None