ocrd_network.runtime_data.network_agents module

ocrd_network.runtime_data.network_agents.deploy_agent_native_get_pid_hack(logger: Logger, ssh_client, start_cmd: str)

ocrd_network.runtime_data.network_agents.deploy_agent_docker_template(logger: Logger, docker_client, start_cmd: str)

logger.debug(f”Executing command: {start_cmd}”) res = docker_client.containers.run(“debian”, “sleep 500s”, detach=True, remove=True) assert res and res.id, f”Starting docker network agent has failed with command: {start_cmd}” return res.id

class ocrd_network.runtime_data.network_agents.DataNetworkAgent(processor_name: str, deploy_type: DeployType, agent_type: AgentType, host: str, init_by_config: bool, pid: Any | None = None)

Bases: object

class ocrd_network.runtime_data.network_agents.DataProcessingWorker(processor_name: str, deploy_type: DeployType, host: str, init_by_config: bool, pid: Any | None = None)

Bases: DataNetworkAgent

deploy_network_agent(logger: Logger, connector_client, database_url: str, queue_url: str)

class ocrd_network.runtime_data.network_agents.DataProcessorServer(processor_name: str, deploy_type: DeployType, host: str, port: int, init_by_config: bool, pid: Any | None = None)

Bases: DataNetworkAgent

deploy_network_agent(logger: Logger, connector_client, database_url: str)