From 06fa5105100f685a4f17c3f643f85eb88b45f7e0 Mon Sep 17 00:00:00 2001 From: Wez Furlong Date: Thu, 10 Apr 2025 14:29:49 -0700 Subject: [PATCH] kumo.spawn_task: move away from LocalSet This is lingering from the past; we don't need LocalSet any more. I thought this might be causing some scheduling issues, but it was neutral overall, so this commit is really just a code cleanup. --- crates/kumo-server-common/src/lib.rs | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/crates/kumo-server-common/src/lib.rs b/crates/kumo-server-common/src/lib.rs index 2d3e0d7b..ec3f8698 100644 --- a/crates/kumo-server-common/src/lib.rs +++ b/crates/kumo-server-common/src/lib.rs @@ -7,7 +7,6 @@ use mlua::{Function, Lua, LuaSerdeExt, Value, Variadic}; use mod_redis::RedisConnKey; use serde::{Deserialize, Serialize}; use std::sync::atomic::AtomicUsize; -use tokio::task::LocalSet; pub mod config_handle; pub mod diagnostic_logging; @@ -448,11 +447,9 @@ pub fn register(lua: &Lua) -> anyhow::Result<()> { .on_thread_park(kumo_server_memory::purge_thread_cache) .build() .unwrap(); - let local_set = LocalSet::new(); let event_name = params.event_name.clone(); - let result = - local_set.block_on(&runtime, async move { params.run().await }); + let result = runtime.block_on(async move { params.run().await }); if let Err(err) = result { tracing::error!("Error while dispatching {event_name}: {err:#}"); }