Skip to content

Commit a453b67

Browse files
author
anna-singleton-resolver
committed
test: always create futures in the correct event loop
1 parent 617a5fe commit a453b67

1 file changed

Lines changed: 2 additions & 1 deletion

File tree

tests/functional/conftest.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,4 @@
1+
import asyncio
12
import os
23
import uuid
34
from asyncio import Future, Queue, Task, create_task
@@ -214,7 +215,7 @@ async def send(self, image_data: ImageData) -> ClassificationOutput:
214215

215216
if image_data.correlation_id is None:
216217
image_data.correlation_id = str(uuid.uuid4())
217-
future: Future[ClassificationOutput] = Future()
218+
future = asyncio.get_event_loop().create_future()
218219
self._pending_results[image_data.correlation_id] = future
219220

220221
await self._request_queue.put(image_data)

0 commit comments

Comments
 (0)