3.3. Модуль aiomisc_worker

3.3.1. Модуль aiomisc_worker.forking

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

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)

Базовые классы: 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

aiomisc_worker.process_inner.worker_inner() → None

3.3.4. Модуль aiomisc_worker.protocol

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

Базовые классы: 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])

Базовые классы: Protocol

fd: BinaryIO | IO[bytes]

class aiomisc_worker.protocol.Protocol

Базовые классы: ABC

PACKET_HEADER = <_struct.Struct object>

receive() → Any

send(payload: Any) → None

class aiomisc_worker.protocol.SocketIOProtocol(sock: socket)

Базовые классы: Protocol

sock: socket

3.3.5. Модуль aiomisc_worker.worker

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