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

Add unit test for sync=True change.

Browse Source 
When sync=True, re-raise exceptions from the worker.
This commit is contained in:
Ryan Branche
2020-02-28 14:47:28 -08:00
parent 2f14c122e4
commit d7d0b0dfb4
2 changed files with 14 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
django_q/tests/test_cluster.py
+6 -1
View File
@@ -18,7 +18,7 @@ from django_q.models import Task, Success
from django_q.conf import Conf
from django_q.status import Stat
from django_q.brokers import get_broker, Broker
from django_q.tests.tasks import multiply
from django_q.tests.tasks import multiply, TaskError
from django_q.queues import Queue
@@ -45,6 +45,11 @@ def test_sync(broker):
task = async_task('django_q.tests.tasks.count_letters', DEFAULT_WORDLIST, broker=broker, sync=True)
assert result(task) == 1506
@pytest.mark.django_db
def test_sync_raise_exception(broker):
with pytest.raises(TaskError):
async_task('django_q.tests.tasks.raise_exception', broker=broker, sync=True)
@pytest.mark.django_db
def test_cluster_initial(broker):