Skip to content

Commit 9c1ea09

Browse files
committed
Fix issue where tasks weren't being dereferenced
1 parent 0c2708a commit 9c1ea09

File tree

3 files changed

+4
-4
lines changed

3 files changed

+4
-4
lines changed

pyproject.toml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
[project]
22
name = "aiointerpreters"
3-
version = "0.3.0"
3+
version = "0.4.0"
44
description = "Run CPU bound code with subinterpreters using asyncio."
55
readme = "README.md"
66
authors = [

src/aiointerpreters/runner.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -106,12 +106,12 @@ def _coordinator(self) -> None:
106106
# Interpreter closed
107107
workers -= 1
108108
case int(i), False, str(reason):
109-
future, loop = self._futures[i]
109+
future, loop = self._futures.pop(i)
110110
loop.call_soon_threadsafe(
111111
future.set_exception, InterpreterError(reason)
112112
)
113113
case int(i), True, result:
114-
future, loop = self._futures[i]
114+
future, loop = self._futures.pop(i)
115115
loop.call_soon_threadsafe(future.set_result, result)
116116
case other:
117117
raise InterpreterError("Unexpected queue value: ", other)

uv.lock

Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

0 commit comments

Comments
 (0)