prefect.utilities.processutils
Functions
forward_signal_handler
forward_signal_handler(pid: int, signum: int, *signums: int) -> None
Forward subsequent signum events (e.g. interrupts) to respective signums.
setup_signal_handlers_server
setup_signal_handlers_server(pid: int, process_name: str, print_fn: PrintFn) -> None
Handle interrupts of the server gracefully.
setup_signal_handlers_agent
setup_signal_handlers_agent(pid: int, process_name: str, print_fn: PrintFn) -> None
Handle interrupts of the agent gracefully.
setup_signal_handlers_worker
setup_signal_handlers_worker(pid: int, process_name: str, print_fn: PrintFn) -> None
Handle interrupts of workers gracefully.
get_sys_executable
get_sys_executable() -> str
Classes
StreamReaderWrapper
StreamWriterWrapper
Process
Methods:
terminate
kill
send_signal
send_signal(self, signal: int) -> None
pid
returncode
returncode(self) -> Union[int, None]
stdin
stdin(self) -> Union[anyio.abc.ByteSendStream, None]
stdout
stdout(self) -> Union[anyio.abc.ByteReceiveStream, None]
stderr
stderr(self) -> Union[anyio.abc.ByteReceiveStream, None]
