Wie kann man dafür sorgen, dass der Socket-Server Ausnahmen an die TaskGroup weitergibt, von der aus sie gestartet werde ⇐ Python

[Anonymous]

Wie können Ausnahmen, die von einem Socket-Server ausgelöst werden, der in einer Aufgabengruppenaufgabe ausgeführt wird, an die übergeordnete Aufgabengruppe weitergegeben werden? Mit dem gegebenen Beispiel würde ich erwarten, dass der von „process_client_command()“ ausgelöste Fehler vom „exclusive“-Block in „run_server()“ abgefangen wird, aber stattdessen läuft der Server weiter und „Unbehandelte Ausnahme“ wird abgemeldet.
Erster Serverstart:

Code: Select all

$ ./script.py server
DEBUG:asyncio:Using selector: EpollSelector

#  following is printed upon receiving data from client:
DEBUG:__main__:received task from client from client, raising exception...
ERROR:asyncio:Unhandled exception in client_connected_cb
transport: 
Traceback (most recent call last):
File "/tmp/script.py", line 19, in process_client_command
raise RuntimeError("error processing client command")
RuntimeError: error processing client command

Und von einem anderen Terminal aus den Client ausführen:

Code: Select all

$ ./script.py client

Beispiel selbst:

Code: Select all

#!/usr/bin/env python3

import asyncio
import sys
import logging
from logging import Logger

LOGGER: Logger = logging.getLogger(__name__)
logging.basicConfig(stream=sys.stdout, level=logging.DEBUG)

SOCK_PATH = "/tmp/test.sock"

async def process_client_commands() -> None:
async def process_client_command(reader, writer):
data = (await reader.read()).decode()
LOGGER.debug(f"received task {data} from client, raising exception...")
raise RuntimeError("error processing client command")
server = await asyncio.start_unix_server(
process_client_command, SOCK_PATH
)
await server.serve_forever()

async def run_server() -> None:
try:
async with asyncio.TaskGroup() as tg:
tg.create_task(process_client_commands())
except* Exception as exc_group:
LOGGER.debug(f"{len(exc_group.exceptions)} errs caught in exc group")
sys.exit(1)

async def _open_write_socket(msg: str):
try:
_, writer = await asyncio.open_unix_connection(SOCK_PATH)
except FileNotFoundError:
LOGGER.error("server is not running")
sys.exit(1)
LOGGER.debug(f"sending message {msg}")
writer.write(msg.encode())
await writer.drain()
writer.write_eof()
return writer

async def send_msg(msg: str):
writer = await _open_write_socket(msg)
LOGGER.debug("closing the connection")
writer.close()
await writer.wait_closed()

if len(sys.argv)