llm4s-docs
API
Generated with
llm4s-docs/org.llm4s/org.llm4s.agent/org.llm4s.agent.graph/RunEvent

RunEvent

org.llm4s.agent.graph.RunEvent
enum RunEvent

What happened in a run. Durable: persisted in the thread's event log and replayable.

The three events that begin a run record the run's tenantId and principal (as supplied in its RunConfig); the log reads events written before they existed as having neither.

Attributes

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

Members list

Type members

Enum entries

final case class CheckpointCommitted(superstep: Int)
final case class Custom(name: String, version: Int, payload: Value)

A node's own event, from RunContext.emit; name and version identify its payload.

A node's own event, from RunContext.emit; name and version identify its payload.

Attributes

case RunCancelled extends RunEvent

The run was cancelled by interrupting its thread; its checkpoint stays Running for recover.

The run was cancelled by interrupting its thread; its checkpoint stays Running for recover.

Attributes

case RunCompleted extends RunEvent
final case class RunFailed(message: String)
final case class RunRecovered(fromCheckpoint: String, tenantId: Option[String], principal: Option[String])
final case class RunResumed(answered: Vector[String], tenantId: Option[String], principal: Option[String])

A run began by answering these interrupts.

A run began by answering these interrupts.

Attributes

final case class RunStarted(tenantId: Option[String], principal: Option[String])
final case class RunSuspended(interrupts: Vector[String])

The run paused; these interrupts await answers.

The run paused; these interrupts await answers.

Attributes

case RunTimedOut extends RunEvent

The run's deadline expired, stopping it as a cancel does; its checkpoint stays Running for recover.

The run's deadline expired, stopping it as a cancel does; its checkpoint stays Running for recover.

Attributes

final case class StateUpdated(fromCheckpoint: String, asNode: Option[String], tenantId: Option[String], principal: Option[String])

GraphRuntime.updateState committed a new checkpoint over fromCheckpoint, with a state update applied as asNode (the event's nodeId too) when one was named.

GraphRuntime.updateState committed a new checkpoint over fromCheckpoint, with a state update applied as asNode (the event's nodeId too) when one was named.

Attributes

case TaskCompleted extends RunEvent
final case class TaskFailed(message: String)
final case class TaskSuspended(interruptId: String)

The task parked a continuation; its pending write holds the question.

The task parked a continuation; its pending write holds the question.

Attributes

final case class ThreadForked(fromThread: String, fromCheckpoint: String, tenantId: Option[String], principal: Option[String])

GraphRuntime.fork created this thread from checkpoint fromCheckpoint of thread fromThread; the first event of the new thread's log.

GraphRuntime.fork created this thread from checkpoint fromCheckpoint of thread fromThread; the first event of the new thread's log.

Attributes

Generated with