Skip to content

Commit 617a5fe

Browse files
author
anna-singleton-resolver
committed
test: remove results buffer
1 parent 3cac70b commit 617a5fe

1 file changed

Lines changed: 0 additions & 2 deletions

File tree

tests/functional/conftest.py

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -175,7 +175,6 @@ class StreamingSender:
175175
"""
176176

177177
def __init__(self, grpc_channel: Channel, options: AthenaOptions) -> None:
178-
self._results: list[ClassificationOutput] = []
179178
self._request_queue: Queue[ImageData] = Queue()
180179
self._pending_results: dict[str, Future[ClassificationOutput]] = {}
181180

@@ -200,7 +199,6 @@ async def _run(self, grpc_channel: Channel, options: AthenaOptions) -> None:
200199
output.correlation_id
201200
)
202201
future.set_result(output)
203-
self._results.append(output)
204202

205203
async def _send_from_queue(self) -> AsyncIterator[ImageData]:
206204
"""Async generator to yield requests from the queue."""

0 commit comments

Comments
 (0)