yadunut/clan-core
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Fix: typing in async_run

Browse Source
This commit is contained in:
Johannes Kirschbauer
2025-05-16 17:44:53 +02:00
parent 29811cd0dc
commit 211ca59441
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
pkgs/clan-cli/clan_cli/async_run.py
View File

@@ -122,8 +122,8 @@ def set_async_ctx(ctx: AsyncContext) -> None:
class AsyncThread(threading.Thread, Generic[P, R]): class AsyncThread(threading.Thread, Generic[P, R]):
function: Callable[P, R] function: Callable[P, R]
args: Any args: tuple[Any, ...]
kwargs: Any kwargs: dict[str, Any]
result: AsyncResult[R] | None result: AsyncResult[R] | None
finished: bool finished: bool
condition: threading.Condition condition: threading.Condition
@@ -155,6 +155,7 @@ class AsyncThread(threading.Thread, Generic[P, R]):
""" """
try: try:
set_async_ctx(self.async_opts.async_ctx) set_async_ctx(self.async_opts.async_ctx)
# Arguments for ParamSpec "P@AsyncThread" are missing
self.result = AsyncResult(_result=self.function(*self.args, **self.kwargs)) self.result = AsyncResult(_result=self.function(*self.args, **self.kwargs))
except Exception as ex: except Exception as ex:
self.result = AsyncResult(_result=ex) self.result = AsyncResult(_result=ex)