feat: task scheduler (#2406)

Signed-off-by: Ryan Olson <ryanolson@users.noreply.github.com>
Signed-off-by: Hannah Zhang <hannahz@nvidia.com>

Author: ryanolson

Cargo.lock

@@ -59,7 +59,7 @@ tempfile = "3"
 thiserror = { version = "2.0.11" }
 tokio = { version = "1", features = ["full"] }
 tokio-stream = { version = "0.1" }
-tokio-util = { version = "0.7", features = ["codec", "net"] }
+tokio-util = { version = "0.7", features = ["codec", "net", "rt"] }
 tower-http = {version = "0.6", features=["trace"]}
 axum = { version = "0.8" , features = ["macros"]}
 tracing = { version = "0.1" }

Cargo.toml

@@ -19,5 +19,6 @@ pub mod leader_worker_barrier;
 pub mod pool;
 pub mod stream;
 pub mod task;
+pub mod tasks;
 pub mod typed_prefix_watcher;
 pub mod worker_monitor;