Subprocess Monitor

SubprocessMonitor use SubprocessHost as backend for cacheing output of a subprocess.

class duetector.monitors.subprocess_monitor.SubprocessHost(timeout, backend, poll_szie=1024, bufsize=32768, kill_timeout=5, restart_times=0)

Bases: object

_poll(tracer: SubprocessTracer, output)

_writeline(json_str: str, io: IO)

attach(tracer: SubprocessTracer)

detach(tracer: SubprocessTracer)

is_alive(tracer: SubprocessTracer)

notify_init(tracer: SubprocessTracer)

notify_poll(tracer: SubprocessTracer)

notify_stop(tracer: SubprocessTracer)

poll(tracer: SubprocessTracer)

Poll a tracer.

poll_all()

Poll all tracers.

set_callback(tracer, callback)

Set callback for tracer.

shutdown()

class duetector.monitors.subprocess_monitor.SubprocessMonitor(config: dict[str, Any] | None = None, *args, **kwargs)

Bases: Monitor

property auto_init

Auto init tracers when init monitor.

property bufsize

Buffer size for subprocess.

config_scope: str | None = 'monitor.subprocess'

Config scope for monitor.

default_config = {'auto_init': True, 'backend_args': {'max_workers': 10}, 'bufsize': 32768, 'disabled': False, 'kill_timeout': 5, 'poller': {'call_when_shutdown': True, 'interval_ms': 500}, 'pool_size': 1024, 'restart_times': 0, 'timeout': 0.01}

Default config for monitor.

Two sub-configs are available:

• backend_args: config for self._backend_imp

• poller: config for Poller

init()

property kill_timeout

Timeout for kill subprocess.

poll(tracer: SubprocessTracer)

Poll a tracer. Should be implemented by subclass.

poll_all()

Poll all tracers. Depends on self.poll.

property poll_szie

Poll size for subprocess.

shutdown()

Shutdown the monitor.

property timeout

Timeout for poll.