インスタンス内 websockets asyncio のスタックトレースが出ない（処理は止まる）

Question

環境

• Ubuntu 20.04.1 LTS
• Python 3.8.5
• • websockets 8.1

概要

以下のコードにて、ゼロ割をしても処理が止まるだけでエラーが出ません。
どうにか出させる方法はありますか？

前提条件

25行目以下コメントセパレータよりも下ではasyncioを使用したくありません。
（クラス・インスタンス内で収めたい）

# ---

client.py

問題のコード

import asyncio
import websockets

class Hoge(object):
    def __init__(self):
        self.uri = 'ws://localhost:8765'

    def __call__(self, func):
        async def stream(func):
            async with websockets.connect(self.uri) as ws:
                while not ws.closed:
                    response = await ws.recv()
                    func(response)
        self.loop = asyncio.get_event_loop()
        self.loop.create_task(stream(func))
        return stream

    def run(self):
        self.loop.run_forever()

class API(object):
    def __init__(self):
        self.websocket = Hoge()

# ---

api = API()

@api.websocket
def recv(msg):
    print(msg)
    a = 1.0 / 0.0  # スタックトレースを吐かずに止まる

api.websocket.run()

server.py

下記コードのエラーは無視

import asyncio
import websockets
import time

async def hello(websocket, path):
    while True:
        await websocket.send('hello')
        time.sleep(1.0)

start_server = websockets.serve(hello, "localhost", 8765)
asyncio.get_event_loop().run_until_complete(start_server)
asyncio.get_event_loop().run_forever()

Answer 1

n145235 さんのアンサーを参考にただ traceback に置き換えてみました。

import traceback
〜
try:
    func(response)
except Exception:
    traceback.print_exc()
    self.loop.stop()
〜

$ python client.py 
hello
Traceback (most recent call last):
  File "client.py", line 15, in stream
    func(response)
  File "client.py", line 37, in recv
    a = 1.0 / 0.0  # スタックトレースを吐かずに止まる
ZeroDivisionError: float division by zero

実際に適用する環境で試してみます。ありがとうございました。

Answer 2

単純に下記のように呼び出し側で例外を捕捉するのではだめなのでしょうか。

class Hoge(object):
(略)
    def __call__(self, func):
        async def stream(func):
            async with websockets.connect(self.uri) as ws:
                while not ws.closed:
                    response = await ws.recv()
                    try:
                        func(response)
                    except ZeroDivisionError as e: # 捕捉したい例外に応じて変える。
                        print(str(e))
                        self.loop.stop()  # イベントループを止めるため追加
(略)

Comments

[shirasublue]

例外そのものは見えるようになりましたが、
可能であれば通常のエラーのようにスタックトレースを表示したいです。
参考にしてみます。ありがとうございます。