Skip to content

aea.runner

This module contains the implementation of AEA multiple instances runner.

AEAInstanceTask Objects

class AEAInstanceTask(AbstractExecutorTask)

Task to run agent instance.

__init__

def __init__(agent: AEA) -> None

Init AEA instance task.

Arguments:

  • agent: AEA instance to run within task.

id

@property
def id() -> str

Return agent name.

start

def start() -> None

Start task.

stop

def stop() -> None

Stop task.

create_async_task

def create_async_task(loop: AbstractEventLoop) -> TaskAwaitable

Return asyncio Task for task run in asyncio loop.

Arguments:

  • loop: abstract event loop

Returns:

task to run runtime

AEARunner Objects

class AEARunner(AbstractMultipleRunner)

Run multiple AEA instances.

__init__

def __init__(
    agents: Sequence[AEA],
    mode: str,
    fail_policy: ExecutorExceptionPolicies = ExecutorExceptionPolicies.
    propagate
) -> None

Init AEARunner.

Arguments:

  • agents: sequence of AEA instances to run.
  • mode: executor name to use.
  • fail_policy: one of ExecutorExceptionPolicies to be used with Executor