AgentWorker

org.llm4s.agent.service.AgentWorker
See theAgentWorker companion class
@Experimental
object AgentWorker

Attributes

Companion
class
Graph
Supertypes
class Object
trait Matchable
class Any
Self type

Members list

Value members

Concrete methods

def apply(queue: RunQueue, checkpointer: Checkpointer, agents: Seq[QueuedAgent], settings: WorkerSettings, queueSettings: RunQueueSettings): Result[AgentWorker]

A worker that runs queue's entries for agents - each an id the entries name, its runtime over checkpointer, the store queue is in - with settings, holding leases by queueSettings.lease and reclaiming closed entries after queueSettings.ticketLifetime. Refuses no agents, and two with one id (ValidationError).

A worker that runs queue's entries for agents - each an id the entries name, its runtime over checkpointer, the store queue is in - with settings, holding leases by queueSettings.lease and reclaiming closed entries after queueSettings.ticketLifetime. Refuses no agents, and two with one id (ValidationError).

Attributes

Concrete fields

val ExhaustedResult: String

The synthetic result a tool call left unanswered gets when an exhausted entry's thread is settled.

The synthetic result a tool call left unanswered gets when an exhausted entry's thread is settled.

Attributes

The reserved thread id AgentWorker.health reads the store at: it has no checkpoints.

The reserved thread id AgentWorker.health reads the store at: it has no checkpoints.

Attributes

The reserved thread id whose claim keeps two instances from sweeping one store at once.

The reserved thread id whose claim keeps two instances from sweeping one store at once.

Attributes