chore: remove debug data_received logging
This commit is contained in:
parent
81e36bf859
commit
94e3153e39
|
|
@ -343,18 +343,8 @@ async def entrypoint(ctx: JobContext) -> None:
|
||||||
type(exc).__name__, exc, exc_info=True,
|
type(exc).__name__, exc, exc_info=True,
|
||||||
)
|
)
|
||||||
|
|
||||||
# Debug: log ALL data_received events to verify the event fires
|
|
||||||
def _debug_data_received(dp):
|
|
||||||
logger.info(
|
|
||||||
"DEBUG data_received: type=%s topic=%s data_len=%d",
|
|
||||||
type(dp).__name__,
|
|
||||||
getattr(dp, 'topic', 'NO_TOPIC_ATTR'),
|
|
||||||
len(getattr(dp, 'data', b'')),
|
|
||||||
)
|
|
||||||
|
|
||||||
# Use ensure_future because ctx.room.on() uses a sync event emitter
|
# Use ensure_future because ctx.room.on() uses a sync event emitter
|
||||||
# (same pattern as the "disconnected" handler above)
|
# (same pattern as the "disconnected" handler above)
|
||||||
ctx.room.on("data_received", _debug_data_received)
|
|
||||||
ctx.room.on("data_received", lambda dp: asyncio.ensure_future(_on_data_received(dp)))
|
ctx.room.on("data_received", lambda dp: asyncio.ensure_future(_on_data_received(dp)))
|
||||||
|
|
||||||
except Exception as exc:
|
except Exception as exc:
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue