Function sync_callback

src/watchdog.py:32–37

(msg)

def make_sync_callback(loop, async_callback, logger=None):
    def sync_callback(msg):
        try:
            loop.call_soon_threadsafe(asyncio.create_task, async_callback(msg))
        except Exception as e:
            if logger:
                logger.error(f"Failed to schedule callback on event loop: {e}")
    return sync_callback

class WebsocketWatchdog: