Skip to content

aea.agent

This module contains the implementation of a generic agent.

Agent Objects

class Agent(AbstractAgent,  WithLogger)

This class provides an abstract base class for a generic agent.

__init__

 | __init__(identity: Identity, connections: List[Connection], loop: Optional[AbstractEventLoop] = None, period: float = 1.0, loop_mode: Optional[str] = None, runtime_mode: Optional[str] = None, storage_uri: Optional[str] = None, logger: Logger = _default_logger, task_manager_mode: Optional[str] = None) -> None

Instantiate the agent.

Arguments:

  • identity: the identity of the agent.
  • connections: the list of connections of the agent.
  • loop: the event loop to run the connections.
  • period: period to call agent's act
  • loop_mode: loop_mode to choose agent run loop.
  • runtime_mode: runtime mode to up agent.
  • storage_uri: optional uri to set generic storage
  • task_manager_mode: task manager mode.

Returns:

None

storage_uri

 | @property
 | storage_uri() -> Optional[str]

Return storage uri.

is_running

 | @property
 | is_running() -> bool

Get running state of the runtime and agent.

is_stopped

 | @property
 | is_stopped() -> bool

Get running state of the runtime and agent.

identity

 | @property
 | identity() -> Identity

Get the identity.

inbox

 | @property
 | inbox() -> InBox

Get the inbox.

The inbox contains Envelopes from the Multiplexer. The agent can pick these messages for processing.

Returns:

InBox instance

outbox

 | @property
 | outbox() -> OutBox

Get the outbox.

The outbox contains Envelopes for the Multiplexer. Envelopes placed in the Outbox are processed by the Multiplexer.

Returns:

OutBox instance

name

 | @property
 | name() -> str

Get the agent name.

tick

 | @property
 | tick() -> int

Get the tick or agent loop count.

Each agent loop (one call to each one of act(), react(), update()) increments the tick.

state

 | @property
 | state() -> RuntimeStates

Get state of the agent's runtime.

Returns:

RuntimeStates

period

 | @property
 | period() -> float

Get a period to call act.

runtime

 | @property
 | runtime() -> BaseRuntime

Get the runtime.

setup

 | setup() -> None

Set up the agent.

Returns:

None

start

 | start() -> None

Start the agent.

Performs the following:

  • calls start() on runtime.
  • waits for runtime to complete running (blocking)

Returns:

None

handle_envelope

 | handle_envelope(envelope: Envelope) -> None

Handle an envelope.

Arguments:

  • envelope: the envelope to handle.

Returns:

None

act

 | act() -> None

Perform actions on period.

Returns:

None

stop

 | stop() -> None

Stop the agent.

Performs the following:

  • calls stop() on runtime
  • waits for runtime to stop (blocking)

Returns:

None

teardown

 | teardown() -> None

Tear down the agent.

Returns:

None

get_periodic_tasks

 | get_periodic_tasks() -> Dict[Callable, Tuple[float, Optional[datetime.datetime]]]

Get all periodic tasks for agent.

Returns:

dict of callable with period specified

get_message_handlers

 | get_message_handlers() -> List[Tuple[Callable[[Any], None], Callable]]

Get handlers with message getters.

Returns:

List of tuples of callables: handler and coroutine to get a message

exception_handler

 | exception_handler(exception: Exception, function: Callable) -> bool

Handle exception raised during agent main loop execution.

Arguments:

  • exception: exception raised
  • function: a callable exception raised in.

Returns:

bool, propagate exception if True otherwise skip it.