tianshu 0.1.0

Async Rust workflow engine — define workflows as trait implementations and run them on a pluggable scheduler
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56

// Copyright 2026 Desicool
//
// SPDX-License-Identifier: Apache-2.0

pub mod case;
pub mod compact;
pub mod context;
pub mod engine;
pub mod llm;
pub mod llm_resilient;
pub mod observe;
pub mod poll;
pub mod registry;
pub mod retry;
pub mod session;
pub mod spawn;
pub mod stage;
pub mod store;
pub mod token;
pub mod tool;
pub mod tool_loop;
pub mod workflow;

// Re-exports
pub use case::{make_case, Case, ExecutionState};
pub use compact::{
    CompactionStrategy, LlmSummaryCompaction, ManagedConversation, TruncationCompaction,
};
pub use context::WorkflowContext;
pub use engine::{
    shutdown_signal, ExecutionMode, SchedulerEnvironment, SchedulerV2, ShutdownSignal,
    ShutdownTrigger, TickResult,
};
pub use llm::{
    LlmMessage, LlmProvider, LlmRequest, LlmResponse, LlmStreamEvent, LlmTool, LlmUsage,
    StreamingLlmProvider, ToolCall, ToolResult,
};
pub use llm_resilient::ResilientLlmProvider;
pub use observe::{
    observe_llm_call, LlmCallRecord, ObservedLlmProvider, Observer, RetryRecord, StepRecord,
    ToolCallRecord, WorkflowRecord,
};
pub use poll::{IntentRouterV2, PollEvaluator, PollMatch, ResourceFetcher};
pub use registry::WorkflowRegistry;
pub use retry::{with_retry, ErrorClass, RetryContext, RetryPolicy};
pub use session::Session;
pub use spawn::{ChildHandle, ChildStatus, ChildrenResult, SpawnConfig};
pub use stage::{run_stages, StageBase, StageKey, StageOutcome};
pub use store::{
    CaseStore, InMemoryCaseStore, InMemorySessionStore, InMemoryStateStore, SessionStateEntry,
    SessionStore, StateEntry, StateStore,
};
pub use token::{CharTokenCounter, ContextConfig, TokenCounter};
pub use tool::{Tool, ToolRegistry, ToolSafety};
pub use tool_loop::{run_tool_loop, ToolLoopConfig, ToolLoopResult};
pub use workflow::{BaseWorkflow, PollPredicate, WorkflowResult};