Skip to content

Commit bd11f1b

Browse files
author
g97iulio1609
committed
fix: use deque in test to match internal queue type
1 parent 2ecad0f commit bd11f1b

1 file changed

Lines changed: 2 additions & 1 deletion

File tree

tests/experimental/tasks/test_message_queue.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
11
"""Tests for TaskMessageQueue and InMemoryTaskMessageQueue."""
22

3+
from collections import deque
34
from datetime import datetime, timezone
45

56
import anyio
@@ -270,7 +271,7 @@ async def is_empty_with_injection(tid: str) -> bool:
270271
if call_count == 2 and tid == task_id:
271272
# Before second check, inject a message - this simulates a message
272273
# arriving between event creation and the double-check
273-
queue._queues[task_id] = [QueuedMessage(type="request", message=make_request())]
274+
queue._queues[task_id] = deque([QueuedMessage(type="request", message=make_request())])
274275
return await original_is_empty(tid)
275276

276277
queue.is_empty = is_empty_with_injection # type: ignore[method-assign]

0 commit comments

Comments
 (0)