4.5. Runner#

4.5.1. Main Runner#

4.5.2. Local Fragment Runner (Executor)#

class simbricks.runner.fragment_runner.local.__main__.LocalRunner(base_url: str, workdir: Path, global_input_dir: Path | None, namespace: str, ident: int, polling_delay_sec: int, sending_delay_sec: int, runner_ip: str, runner_port: int, proxy_host_ip: str, verbose: bool, output_artifact_relative: bool, event_batch_size: int)#
async connect() None#
async read(length: int) bytes#
async write(data: bytes) None#
async get_events() list[RunnerHeartbeatReq | StartRunReq | KillRunReq | SimulationSigusr1 | SimulatorChangedState | ProxyChangedState] | list[RunnerStarted | RunnerHeartbeat | RunStatus | SimulatorOutput | SimulatorStateChange | ProxyOutput | ProxyStateChange | FragmentStateChange | FragmentOutputArtifact]#
async run() None#
async send_events(events: list[RunnerHeartbeatReq | StartRunReq | KillRunReq | SimulationSigusr1 | SimulatorChangedState | ProxyChangedState] | list[RunnerStarted | RunnerHeartbeat | RunStatus | SimulatorOutput | SimulatorStateChange | ProxyOutput | ProxyStateChange | FragmentStateChange | FragmentOutputArtifact]) None#
async simbricks.runner.fragment_runner.local.__main__.amain()#
simbricks.runner.fragment_runner.local.__main__.setup_logger() Logger#
simbricks.runner.fragment_runner.local.__main__.main()#