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

Adds max rss test

Browse Source
This commit is contained in:
Ilan Steemers
2020-07-08 22:52:07 +02:00
parent 572f810651
commit 0095a93b45
1 changed files with 1 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
django_q/tests/test_cluster.py
+1 -2
View File
@@ -358,8 +358,7 @@ def test_max_rss(broker, monkeypatch):
async_task('django_q.tests.tasks.multiply', 2, 2, broker=broker) async_task('django_q.tests.tasks.multiply', 2, 2, broker=broker)
task_queue = Queue() task_queue = Queue()
result_queue = Queue() result_queue = Queue()
# push two tasks # push the task
pusher(task_queue, stop_event, broker=broker)
pusher(task_queue, stop_event, broker=broker) pusher(task_queue, stop_event, broker=broker)
# worker should exit on recycle # worker should exit on recycle
worker(task_queue, result_queue, Value('f', -1)) worker(task_queue, result_queue, Value('f', -1))