Run each async udf in its own thread#124

Open

nkitsaini wants to merge 15 commits into

mainfrom

users/asaini/event-loop-worker

Commits on Jun 9, 2026

Fix async UDF event loop starvation under heavy load in Jupyter

authored and
nkitsaini
committed
Ensure proper cancellation of async UDFs in dedicated loop

authored and
nkitsaini
committed
Fix create_task expecting coroutine, use ensure_future for wrapped future

authored and
nkitsaini
committed
Call Application.shutdown() when replacing UDF server

authored and
nkitsaini
committed
Propagate cancellation to UDF loop and prevent thread leak on failure

authored and
nkitsaini
committed
Fix udf_future NameError and lazily initialize UDF event loop

authored and
nkitsaini
committed
Reset UDF loop state in shutdown() to allow safe reuse

authored and
nkitsaini
committed
Use thread-per-request for async UDFs instead of shared event loop

authored and
nkitsaini
committed
Add cancellable wrapper for responsive async UDF cancellation

authored and
nkitsaini
committed
Fix event loop closed error and add comprehensive UDF dispatch tests

authored and
nkitsaini
committed
reuse event loop across requests on same thread

nkitsaini
and
cursoragent
committed

Commits on Jun 10, 2026

Commits on Jun 11, 2026