3.3. aiomisc_worker module

3.3.1. aiomisc_worker.forking module

aiomisc_worker.forking.at_exit() → None

aiomisc_worker.forking.fork(worker_id: bytes, cookie: bytes, address: str | tuple[str, int]) → None

aiomisc_worker.forking.handle_interrupt(*_: Any) → None

aiomisc_worker.forking.main() → int

3.3.2. aiomisc_worker.process module

class aiomisc_worker.process.Worker(log_level: str, log_format: str, address: str | tuple[str, int], cookie: bytes, worker_id: bytes, env: Mapping[str, str], initializer: Callable[[...], Any], initializer_args: Any, initializer_kwargs: Any)

Bases: object

close() → None

property is_running: bool

kill(sig: int = Signals.SIGINT) → None

aiomisc_worker.process.at_exit() → None

aiomisc_worker.process.main() → int

3.3.3. aiomisc_worker.process_inner module

aiomisc_worker.process_inner.worker_inner() → None

3.3.4. aiomisc_worker.protocol module

class aiomisc_worker.protocol.AsyncProtocol(reader: StreamReader, writer: StreamWriter)

Bases: object

PACKET_HEADER = <_struct.Struct object>

close() → None

async receive() → Any

async send(payload: Any) → None

class aiomisc_worker.protocol.FileIOProtocol(fd: BinaryIO | IO[bytes])

Bases: Protocol

fd: BinaryIO | IO[bytes]

class aiomisc_worker.protocol.Protocol

Bases: ABC

PACKET_HEADER = <_struct.Struct object>

receive() → Any

send(payload: Any) → None

class aiomisc_worker.protocol.SocketIOProtocol(sock: socket)

Bases: Protocol

sock: socket

3.3.5. aiomisc_worker.worker module

aiomisc_worker.worker.bad_initializer(address: str | tuple[str, int], cookie: bytes, worker_id: bytes, exc: BaseException) → None

aiomisc_worker.worker.execute(protocol: SocketIOProtocol) → None

aiomisc_worker.worker.on_cancel_signal(*_: Any) → None

aiomisc_worker.worker.on_exception(exc_type: type[BaseException] | None, exc_value: BaseException | None, exc_tb: TracebackType | None) → None

aiomisc_worker.worker.worker(address: str | tuple[str, int], cookie: bytes, worker_id: bytes) → None