adf_core_python.core.launcher.connect package

adf_core_python.core.launcher.connect package#

Submodules#

adf_core_python.core.launcher.connect.component_launcher module#

class adf_core_python.core.launcher.connect.component_launcher.ComponentLauncher(host: str, port: int, logger: BoundLogger)#

ベースクラス: object

check_kernel_connection(timeout: int = 30, retry_interval: float = 5.0) → bool#

Attempts to connect to the kernel multiple times within the specified timeout period.

パラメータ:

  • timeout (int) -- Total timeout duration in seconds

  • retry_interval (float) -- Interval between retry attempts in seconds

戻り値:

True if connection successful, False otherwise

戻り値の型:

bool

connect(agent: Agent, _request_id: int) → None#
generate_request_id() → int#
make_connection() → Connection#

adf_core_python.core.launcher.connect.connection module#

class adf_core_python.core.launcher.connect.connection.Connection(host: str, port: int)#

ベースクラス: object

connect() → None#

Connect to the kernel

例外:

  • socket.timeout -- If the connection times out

  • socket.error -- If there is an error connecting to the socket

message_received(agent_message_received: Callable) → None#
parse_message_from_kernel() → None#

Parse messages from the kernel

例外:

  • ServerError -- If there is an error reading from the socket

  • AgentError -- If there is an error in the agent calculation

send_msg(msg: Any) → None#

adf_core_python.core.launcher.connect.connector module#

class adf_core_python.core.launcher.connect.connector.Connector#

ベースクラス: ABC

abstractmethod connect(component_launcher: ComponentLauncher, gateway_launcher: GatewayLauncher | None, config: Config, loader: AbstractLoader) → dict[Thread, Event]#
get_connected_agent_count() → int#

adf_core_python.core.launcher.connect.connector_ambulance_center module#

class adf_core_python.core.launcher.connect.connector_ambulance_center.ConnectorAmbulanceCenter#

ベースクラス: Connector

connect(component_launcher: ComponentLauncher, gateway_launcher: GatewayLauncher | None, config: Config, loader: AbstractLoader) → dict[Thread, Event]#

adf_core_python.core.launcher.connect.connector_ambulance_team module#

class adf_core_python.core.launcher.connect.connector_ambulance_team.ConnectorAmbulanceTeam#

ベースクラス: Connector

connect(component_launcher: ComponentLauncher, gateway_launcher: GatewayLauncher | None, config: Config, loader: AbstractLoader) → dict[Thread, Event]#

adf_core_python.core.launcher.connect.connector_fire_brigade module#

class adf_core_python.core.launcher.connect.connector_fire_brigade.ConnectorFireBrigade#

ベースクラス: Connector

connect(component_launcher: ComponentLauncher, gateway_launcher: GatewayLauncher | None, config: Config, loader: AbstractLoader) → dict[Thread, Event]#

adf_core_python.core.launcher.connect.connector_fire_station module#

class adf_core_python.core.launcher.connect.connector_fire_station.ConnectorFireStation#

ベースクラス: Connector

connect(component_launcher: ComponentLauncher, gateway_launcher: GatewayLauncher | None, config: Config, loader: AbstractLoader) → dict[Thread, Event]#

adf_core_python.core.launcher.connect.connector_police_force module#

class adf_core_python.core.launcher.connect.connector_police_force.ConnectorPoliceForce#

ベースクラス: Connector

connect(component_launcher: ComponentLauncher, gateway_launcher: GatewayLauncher | None, config: Config, loader: AbstractLoader) → dict[Thread, Event]#

adf_core_python.core.launcher.connect.connector_police_office module#

class adf_core_python.core.launcher.connect.connector_police_office.ConnectorPoliceOffice#

ベースクラス: Connector

connect(component_launcher: ComponentLauncher, gateway_launcher: GatewayLauncher | None, config: Config, loader: AbstractLoader) → dict[Thread, Event]#

Module contents#

目次