4.5. 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()