Skip to content

Commit 3aa660f

Browse files
committed
remove cancel error
1 parent a8aef37 commit 3aa660f

File tree

1 file changed

+3
-6
lines changed

1 file changed

+3
-6
lines changed

packages/common-library/src/common_library/async_tools.py

Lines changed: 3 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -15,12 +15,9 @@ def decorator(func: Callable[P, R]) -> Callable[P, Awaitable[R]]:
1515
@functools.wraps(func)
1616
async def wrapper(*args: P.args, **kwargs: P.kwargs) -> R:
1717
loop = asyncio.get_running_loop()
18-
return await asyncio.wait_for(
19-
loop.run_in_executor(
20-
executor, functools.partial(func, *args, **kwargs)
21-
),
22-
timeout=2,
23-
) # wait_for is temporary for debugging async jobs
18+
return await loop.run_in_executor(
19+
executor, functools.partial(func, *args, **kwargs)
20+
)
2421

2522
return wrapper
2623

0 commit comments

Comments
 (0)