From 4af553e22ee5dd5342c024202d423d66e41770c7 Mon Sep 17 00:00:00 2001
From: Pratyush Sharma <56130065+pratyush618@users.noreply.github.com>
Date: Sun, 22 Mar 2026 12:16:42 +0530
Subject: [PATCH 1/2] docs: add smart scheduling to 0.9.0 changelog

---
 docs/changelog.md | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/docs/changelog.md b/docs/changelog.md
index ca4b215..e90ff7d 100644
--- a/docs/changelog.md
+++ b/docs/changelog.md
@@ -12,6 +12,7 @@ All notable changes to taskito are documented here.
 - **Worker status transitions** -- workers report `active → draining → stopped` status; shutdown signal sets status to `"draining"` before drain timeout, visible in `queue.workers()` and the dashboard
 - **Orphan rescue prep** -- `list_claims_by_worker` storage method enables future orphaned job rescue when dead workers are detected
 - **Task result streaming** -- `current_job.publish(data)` streams partial results from inside tasks; `job.stream()` / `await job.astream()` iterates partial results as they arrive; built on existing `task_logs` infrastructure with `level="result"` (no new tables or Rust changes); FastAPI SSE endpoint supports `?include_results=true` to stream partial results alongside progress
+- **Smart scheduling** -- adaptive backpressure polling (50ms base → 200ms max backoff when idle, instant reset on dispatch); per-task duration cache tracks average execution time in-memory; weighted least-loaded dispatch for prefork pool factors in task duration (`score = in_flight × avg_duration`)
 
 ### Internal
 
@@ -22,6 +23,9 @@ All notable changes to taskito are documented here.
 - `workers` table gains 4 columns: `started_at`, `hostname`, `pid`, `pool_type` (all backends + migrations)
 - `reap_dead_workers` returns `Vec<String>` (reaped worker IDs) instead of `u64`; enables `WORKER_OFFLINE` event emission
 - New storage methods: `update_worker_status`, `list_claims_by_worker` across all 3 backends
+- `Scheduler::run()` uses adaptive polling with exponential backoff (50ms → 200ms max); `tick()` returns `bool` for feedback
+- `TaskDurationCache` in-memory HashMap tracks per-task avg wall_time_ns, updated on every `handle_result()`
+- `weighted_least_loaded()` dispatch strategy in `prefork/dispatch.rs`; `aging_factor` field added to `SchedulerConfig`
 
 ---
 

From 63433e9f594ad120455fe4c835f1a91d7621558a Mon Sep 17 00:00:00 2001
From: Pratyush Sharma <56130065+pratyush618@users.noreply.github.com>
Date: Sun, 22 Mar 2026 12:20:05 +0530
Subject: [PATCH 2/2] chore: bump version to 0.10.0

---
 crates/taskito-async/Cargo.toml  |  2 +-
 crates/taskito-core/Cargo.toml   |  2 +-
 crates/taskito-python/Cargo.toml |  2 +-
 docs/changelog.md                | 18 ++++++++++++++----
 py_src/taskito/__init__.py       |  2 +-
 pyproject.toml                   |  2 +-
 6 files changed, 19 insertions(+), 9 deletions(-)

diff --git a/crates/taskito-async/Cargo.toml b/crates/taskito-async/Cargo.toml
index d98401e..d6a630a 100644
--- a/crates/taskito-async/Cargo.toml
+++ b/crates/taskito-async/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "taskito-async"
-version = "0.9.0"
+version = "0.10.0"
 edition = "2021"
 
 [dependencies]
diff --git a/crates/taskito-core/Cargo.toml b/crates/taskito-core/Cargo.toml
index 823893e..78c8ff3 100644
--- a/crates/taskito-core/Cargo.toml
+++ b/crates/taskito-core/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "taskito-core"
-version = "0.9.0"
+version = "0.10.0"
 edition = "2021"
 
 [features]
diff --git a/crates/taskito-python/Cargo.toml b/crates/taskito-python/Cargo.toml
index e8dbd41..297a751 100644
--- a/crates/taskito-python/Cargo.toml
+++ b/crates/taskito-python/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "taskito-python"
-version = "0.9.0"
+version = "0.10.0"
 edition = "2021"
 
 [features]
diff --git a/docs/changelog.md b/docs/changelog.md
index e90ff7d..5b15534 100644
--- a/docs/changelog.md
+++ b/docs/changelog.md
@@ -2,6 +2,20 @@
 
 All notable changes to taskito are documented here.
 
+## 0.10.0
+
+### Features
+
+- **Smart scheduling** -- adaptive backpressure polling (50ms base → 200ms max backoff when idle, instant reset on dispatch); per-task duration cache tracks average execution time in-memory; weighted least-loaded dispatch for prefork pool factors in task duration (`score = in_flight × avg_duration`)
+
+### Internal
+
+- `Scheduler::run()` uses adaptive polling with exponential backoff (50ms → 200ms max); `tick()` returns `bool` for feedback
+- `TaskDurationCache` in-memory HashMap tracks per-task avg wall_time_ns, updated on every `handle_result()`
+- `weighted_least_loaded()` dispatch strategy in `prefork/dispatch.rs`; `aging_factor` field added to `SchedulerConfig`
+
+---
+
 ## 0.9.0
 
 ### Features
@@ -12,7 +26,6 @@ All notable changes to taskito are documented here.
 - **Worker status transitions** -- workers report `active → draining → stopped` status; shutdown signal sets status to `"draining"` before drain timeout, visible in `queue.workers()` and the dashboard
 - **Orphan rescue prep** -- `list_claims_by_worker` storage method enables future orphaned job rescue when dead workers are detected
 - **Task result streaming** -- `current_job.publish(data)` streams partial results from inside tasks; `job.stream()` / `await job.astream()` iterates partial results as they arrive; built on existing `task_logs` infrastructure with `level="result"` (no new tables or Rust changes); FastAPI SSE endpoint supports `?include_results=true` to stream partial results alongside progress
-- **Smart scheduling** -- adaptive backpressure polling (50ms base → 200ms max backoff when idle, instant reset on dispatch); per-task duration cache tracks average execution time in-memory; weighted least-loaded dispatch for prefork pool factors in task duration (`score = in_flight × avg_duration`)
 
 ### Internal
 
@@ -23,9 +36,6 @@ All notable changes to taskito are documented here.
 - `workers` table gains 4 columns: `started_at`, `hostname`, `pid`, `pool_type` (all backends + migrations)
 - `reap_dead_workers` returns `Vec<String>` (reaped worker IDs) instead of `u64`; enables `WORKER_OFFLINE` event emission
 - New storage methods: `update_worker_status`, `list_claims_by_worker` across all 3 backends
-- `Scheduler::run()` uses adaptive polling with exponential backoff (50ms → 200ms max); `tick()` returns `bool` for feedback
-- `TaskDurationCache` in-memory HashMap tracks per-task avg wall_time_ns, updated on every `handle_result()`
-- `weighted_least_loaded()` dispatch strategy in `prefork/dispatch.rs`; `aging_factor` field added to `SchedulerConfig`
 
 ---
 
diff --git a/py_src/taskito/__init__.py b/py_src/taskito/__init__.py
index f2982b2..5074fec 100644
--- a/py_src/taskito/__init__.py
+++ b/py_src/taskito/__init__.py
@@ -99,4 +99,4 @@
 
     __version__ = _get_version("taskito")
 except PackageNotFoundError:
-    __version__ = "0.9.0"
+    __version__ = "0.10.0"
diff --git a/pyproject.toml b/pyproject.toml
index ca9e793..754ef95 100644
--- a/pyproject.toml
+++ b/pyproject.toml
@@ -4,7 +4,7 @@ build-backend = "maturin"
 
 [project]
 name = "taskito"
-version = "0.9.0"
+version = "0.10.0"
 description = "Rust-powered task queue for Python. No broker required."
 requires-python = ">=3.10"
 license = { file = "LICENSE" }