CommitTimedOut

org.llm4s.agent.graph.GraphError.CommitTimedOut
final case class CommitTimedOut(threadId: String, after: FiniteDuration) extends GraphError, NonRecoverableError

The run's closing wait - an Async run waiting for its queued commits, or an OnExit run's exit commit - was given up on: a commit had been in the store for after, twice the runtime's ClaimPolicy.ttl, with no commit returning meanwhile, while the run still held its claim. The run ended without waiting for it: its thread is free in this runtime, and its claim is released on a thread of its own. Every Checkpointer must return from each call within a bound it documents, so this is a store that broke that contract, or one whose bound is not well inside after.

The commit given up on, and any queued behind it, may or may not land. One still in the store is fenced by the run's claim: once the release lands, or another run takes the thread over, the store refuses it, but it can land first. So read the thread before acting on it: its latest checkpoint is either the last one the run made durable, still Running - recover continues the run once the thread is free - or the run's outcome, which recover reports as it finds it (NothingToRecover, or PendingInterrupts for a suspended thread). A late commit's events are in the thread's log and reach the thread's subscribers, but never the run's own listeners or its tracing.

Attributes

Graph
Supertypes
trait GraphError
trait LLMError
trait Serializable
trait Product
trait Equals
class Object
trait Matchable
class Any
Show all

Members list

Value members

Inherited methods

def code: Option[String]

Optional error code for programmatic handling

Optional error code for programmatic handling

Attributes

Inherited from:
LLMError
def context: Map[String, String]

Additional context information

Additional context information

Attributes

Inherited from:
LLMError
def correlationId: Option[String]

Error correlation IDs for debugging

Error correlation IDs for debugging

Attributes

Inherited from:
LLMError
def formatted: String

Formatted error message with context

Formatted error message with context

Attributes

Inherited from:
LLMError
def productElementNames: Iterator[String]

Attributes

Inherited from:
Product
def productIterator: Iterator[Any]

Attributes

Inherited from:
Product

Concrete fields

override val message: String

Human-readable error message

Human-readable error message

Attributes