Commit 9968d04 1 parent 260bab7 commit 9968d04 Copy full SHA for 9968d04
File tree 1 file changed +2
-2
lines changed
1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -8,7 +8,7 @@ def test_no_workers() -> None:
8
8
9
9
async def test_no_queues () -> None :
10
10
task_consumer = TaskConsumer (broker_url = "redis://localhost:7777?queues=" )
11
- assert task_consumer .config .max_concurrent_tasks == 10
11
+ assert task_consumer .config .max_concurrent_tasks == 5
12
12
assert task_consumer .broker .task_queue_names == ()
13
13
assert await task_consumer .broker .queue_length () == {}
14
14
@@ -17,7 +17,7 @@ async def test_two_queues() -> None:
17
17
task_consumer = TaskConsumer (
18
18
broker_url = "redis://localhost:7777?name=test&queues=medium,high"
19
19
)
20
- assert task_consumer .config .max_concurrent_tasks == 10
20
+ assert task_consumer .config .max_concurrent_tasks == 5
21
21
assert task_consumer .broker .task_queue_names == (
22
22
"test-queue-medium" ,
23
23
"test-queue-high" ,
You can’t perform that action at this time.
0 commit comments