Merge pull request #345 from tinyhumansai/harness-uplift/tasks-crate

refactor: extract tinyagents-tasks crate (D11 phase 2)

Author: senamakel

AGENTS.md

@@ -7,7 +7,9 @@ compatibility facade crate: consumers depend directly on the focused package
 that owns an API. The public packages are `crates/tinyagents-graph/` (durable
 typed state graphs), `crates/tinyagents-harness/` (provider-neutral model
 calls, tools, middleware, and streaming), `crates/tinyagents-registry/` (the named
-capability catalog), `crates/tinyagents-session/` (durable session data), and
+capability catalog), `crates/tinyagents-session/` (durable session data),
+`crates/tinyagents-tasks/` (graph-independent detached-task registry,
+task stores and orchestration controls), and
 `crates/tinyagents-orchestration/` (direct and durable subagent invocation,
 tools, sessions, lifecycle logic, and focused tests).
 `crates/tinyagents-tracing/` supplies shared opt-in tracing macros, while

Cargo.lock

@@ -3,6 +3,7 @@ members = ["crates/*"]
 default-members = [
     "crates/tinyagents-harness",
     "crates/tinyagents-graph",
+    "crates/tinyagents-tasks",
     "crates/tinyagents-registry",
     "crates/tinyagents-session",
     "crates/tinyagents-runtime",

Cargo.toml

@@ -34,6 +34,10 @@ TinyAgents is a Cargo workspace, not one crate. Depend on the pieces you need:
   `START`/`END`, nodes, conditional edges, `Send` fanout, reducers/channels,
   checkpoints, interrupts, subgraphs, and time travel. Features: `sqlite`,
   `tracing`.
+- **`tinyagents-tasks`** — graph-independent detached-task machinery: task
+  model, `TaskStore` (in-memory and JSONL), `DetachedTaskRegistry`, restart
+  reconciliation, and the `spawn`/`await`/`cancel`/`steer` orchestration tools.
+  Re-exported from `tinyagents_graph::orchestration` for compatibility.
 - **`tinyagents-registry`** — a named capability catalog (models, tools,
   agents, graphs, and routers), plus an offline model price/capability catalog.
 - **`tinyagents-session`** — a SQLite-backed store for session history,

README.md

@@ -15,6 +15,7 @@ futures = { workspace = true }
 rusqlite = { workspace = true, optional = true }
 serde = { workspace = true }
 serde_json = { workspace = true }
+tinyagents-tasks = { path = "../tinyagents-tasks", version = "2.1.3", default-features = false }
 tinyagents-harness = { path = "../tinyagents-harness", version = "2.1.3", default-features = false, features = [
     "langfuse",
 ] }

crates/tinyagents-graph/Cargo.toml

@@ -25,7 +25,7 @@ carry their own `README.md` — see the module map below.
 | `export` | Graph introspection/visualization: topology extraction, Mermaid/JSON export, validation reports. |
 | `goals` | A durable per-thread goal (single "completion contract"), continuation loop, and harness tools. See [`goals/README.md`](goals/README.md). |
 | `observability` | Durable graph observability: journals, status stores, the journaling sink, latency/health rollups, Langfuse export. See [`observability/README.md`](observability/README.md). |
-| `orchestration` | Managed child-work controls (`spawn`/`await`/`cancel`/... ) exposed as harness tools, backed by a `TaskStore`. See [`orchestration/README.md`](orchestration/README.md). |
+| `orchestration` | Managed child-work controls (`spawn`/`await`/`cancel`/... ) exposed as harness tools, backed by a `TaskStore`. Now lives in `tinyagents-tasks` ([README](../../tinyagents-tasks/src/README.md)); this module only re-exports it for compatibility. |
 | `parallel` | `map_reduce` — ordered, bounded-concurrency parallel map/reduce with a configurable failure policy, independent of the graph executor. |
 | `recursion` | Recursion policy and depth tracking: `RecursionFrame`/`RecursionPolicy`/`RecursionStack`/`RunTree` bound and observe nested graph/subgraph/sub-agent recursion. See [`recursion/README.md`](recursion/README.md). |
 | `reducer` | `StateReducer`/`Reducer` implementations (overwrite, append, min/max, set-union, closures) that fold branch updates into committed state at a superstep boundary. See [`reducer/README.md`](reducer/README.md). |

crates/tinyagents-graph/src/README.md

@@ -0,0 +1,11 @@
+//! Compatibility shim: the detached-task machinery moved to `tinyagents-tasks`.
+//!
+//! Every item formerly defined here is re-exported unchanged so existing
+//! `tinyagents_graph::orchestration::*` paths keep compiling. The shim is
+//! permanent for now; prefer `tinyagents_tasks` in new code.
+
+pub use tinyagents_tasks::*;
+
+#[cfg(test)]
+#[path = "orchestration_tests.rs"]
+mod tests;

crates/tinyagents-graph/src/orchestration.rs

@@ -0,0 +1,31 @@
+//! The old graph paths must keep resolving after the move to `tinyagents-tasks`.
+
+use crate::orchestration::{
+    DetachedTaskRegistry, InMemoryTaskStore, JsonlTaskStore, OrchestrationTaskStatus,
+    SteeringRegistry, TaskStore, TaskStoreRegistry, reconcile_orphaned_tasks,
+};
+
+#[test]
+fn old_graph_paths_are_the_tasks_crate_types() {
+    fn same<T>(_: std::marker::PhantomData<T>, _: std::marker::PhantomData<T>) {}
+    same(
+        std::marker::PhantomData::<crate::OrchestrationTaskStatus>,
+        std::marker::PhantomData::<tinyagents_tasks::OrchestrationTaskStatus>,
+    );
+    same(
+        std::marker::PhantomData::<OrchestrationTaskStatus>,
+        std::marker::PhantomData::<tinyagents_tasks::OrchestrationTaskStatus>,
+    );
+    same(
+        std::marker::PhantomData::<SteeringRegistry>,
+        std::marker::PhantomData::<tinyagents_tasks::SteeringRegistry>,
+    );
+    let _ = std::marker::PhantomData::<(
+        InMemoryTaskStore,
+        JsonlTaskStore,
+        TaskStoreRegistry<u8>,
+        DetachedTaskRegistry<(), ()>,
+        Box<dyn TaskStore>,
+    )>;
+    let _ = reconcile_orphaned_tasks;
+}

crates/tinyagents-graph/src/orchestration_tests.rs

@@ -71,7 +71,7 @@ caller-supplied adapter — can be certified by running the same assertions:
   ordering/limit/cycle-termination, `copy_thread` semantics (including
   rejecting a non-empty target), and per-namespace `prune`.
 - `taskstore_contract(store)` — basic CRUD/lifecycle contract for a
-  `graph::orchestration::TaskStore` implementation.
+  `tinyagents_tasks::TaskStore` implementation.
 - `taskstore_concurrent_contract(store: Arc<S>)` — concurrent-access contract
   (no lost updates, no corrupted records under concurrent writers).
 - `taskstore_replay_contract(reopen)` — durability contract: a store reopened

crates/tinyagents-graph/src/testkit/README.md

@@ -17,6 +17,7 @@ serde_json = { workspace = true }
 thiserror = "2"
 parking_lot = "0.12"
 tinyagents-graph = { path = "../tinyagents-graph", version = "2.1.3", default-features = false }
+tinyagents-tasks = { path = "../tinyagents-tasks", version = "2.1.3", default-features = false }
 tinyagents-harness = { path = "../tinyagents-harness", version = "2.1.3", default-features = false }
 tinyagents-session = { path = "../tinyagents-session", version = "2.1.3", default-features = false }
 tinyagents-runtime = { path = "../tinyagents-runtime", version = "2.1.3", default-features = false }