Fix trio with multiple workers

The `shutdown_trigger` argument of `worker_serve` needs to be a callable returning an awaitable, not an awaitable directly.
pgjones · Mar 2, 2020 · 4b614d8 · 4b614d8
1 parent b062659
commit 4b614d8
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/hypercorn/trio/run.py b/src/hypercorn/trio/run.py
@@ -106,6 +106,6 @@ def trio_worker(
 
     shutdown_trigger = None
     if shutdown_event is not None:
-        shutdown_trigger = check_multiprocess_shutdown_event(shutdown_event, trio.sleep)
+        shutdown_trigger = partial(check_multiprocess_shutdown_event, shutdown_event, trio.sleep)
 
     trio.run(partial(worker_serve, app, config, sockets=sockets, shutdown_trigger=shutdown_trigger))