Get the number of messages in the chat history.

Clear the chat history. # Examples ```rust use graph_flow::Context; # #[tokio::main] # async fn main() { let context = Context::new(); context.add_

Middleware to add correlation ID to all requests

Convert a [`SerializableMessage`] into a `rig::completion::Message`, moving the content instead of cloning it. Only available when the "rig" feature

Get a task by ID

Unique identifier for this task. By default, this returns the type name of the implementing struct. Override this method if you need a custom identif

Check if the chat history is empty.

Create a TaskResult that moves to the next task (step-by-step execution). This is a convenience method equivalent to: ```rust # use graph_flow::{Task

Create a TaskResult that moves to the next task and executes it immediately. This is a convenience method equivalent to: ```rust # use graph_flow::{T

Create a new `FanOutTask` with an explicit id and a list of child tasks.

Create a new TaskResult with the given response and next action. The task_id will be set automatically by the graph execution engine. # Examples ``

Create a new message with the specified role and content. The timestamp is automatically set to the current UTC time.

Create a new `FlowRunner` from an `Arc<Graph>` and any `SessionStorage` implementation. # Parameters `graph` - The workflow graph to execute `storag

Create a new session positioned at the given task. Note: `graph_id` is set to `"default"`; assign it explicitly if you store multiple graphs.

Create a new TaskResult with response, next action, and status message. The status message is used to describe the current state of the task. It's on

Set the starting task. Logs a warning and leaves the current start task unchanged if the given task id has not been added to the graph.

Get the start task ID

Create a new system message. # Examples ```rust use graph_flow::SerializableMessage; let msg = SerializableMessage::system("User logged in".to_stri

exercises the deprecated Graph::execute until it is removed

Fallible version of [`Context::set`]. Returns `Err(GraphError::ContextError)` instead of panicking when the value cannot be serialized to JSON.

Create a new user message. # Examples ```rust use graph_flow::SerializableMessage; let msg = SerializableMessage::user("Hello, world!".to_string())

Create a new context with a maximum chat history size. When the chat history exceeds this size, older messages are automatically removed. # Examples

Limit the number of chained `ContinueAndExecute` steps within a single `execute_session` call, guarding against infinite loops in cyclic graphs (defau

Create a new chat history with a maximum message limit. When the limit is exceeded, older messages are automatically removed. # Examples ```rust us

Override the `NextAction` returned by the `FanOutTask` (default: `Continue`).

Build the storage from a pre-configured pool (custom connection limits, timeouts, etc.) and run the schema migration.

Set the timeout applied to each task execution (default: 5 minutes).