@@ -74,7 +74,7 @@ def test_enqueues_job(self) -> None:
74
74
75
75
dummy_task (42 )
76
76
77
- job = self .backend .dequeue (QUEUE , WorkerNumber (0 ), 5 )
77
+ job = self .backend .dequeue (QUEUE , WorkerNumber (0 ), 1 )
78
78
# Plain assert to placate mypy
79
79
assert job is not None , "Failed to get a job after enqueuing one"
80
80
@@ -97,7 +97,7 @@ def test_bulk_enqueues_jobs(self) -> None:
97
97
enqueue (13 )
98
98
enqueue (num = 42 )
99
99
100
- job = self .backend .dequeue (QUEUE , WorkerNumber (0 ), 5 )
100
+ job = self .backend .dequeue (QUEUE , WorkerNumber (0 ), 1 )
101
101
# Plain assert to placate mypy
102
102
assert job is not None , "Failed to get a job after enqueuing one"
103
103
@@ -114,7 +114,7 @@ def test_bulk_enqueues_jobs(self) -> None:
114
114
"First job" ,
115
115
)
116
116
117
- job = self .backend .dequeue (QUEUE , WorkerNumber (0 ), 5 )
117
+ job = self .backend .dequeue (QUEUE , WorkerNumber (0 ), 1 )
118
118
# Plain assert to placate mypy
119
119
assert job is not None , "Failed to get a job after enqueuing one"
120
120
@@ -141,7 +141,7 @@ def test_bulk_enqueues_jobs_batch_size_boundary(self) -> None:
141
141
enqueue (4 )
142
142
143
143
jobs = [
144
- self .backend .dequeue (QUEUE , WorkerNumber (0 ), 5 )
144
+ self .backend .dequeue (QUEUE , WorkerNumber (0 ), 1 )
145
145
for _ in range (4 )
146
146
]
147
147
0 commit comments