PL j dZddlmZddlZddlZddlmZddlmZm Z m Z ej e Z ddejdddZdS)uAsync/sync bridging helpers. The codebase has ~30 sites that schedule a coroutine onto an event loop from a worker thread via :func:`asyncio.run_coroutine_threadsafe`. That function can raise :class:`RuntimeError` (e.g. the loop was closed during a shutdown race), and when it does the coroutine object is never awaited and never closed — which triggers a ``"coroutine '' was never awaited"`` RuntimeWarning and leaks the coroutine's frame until GC. :func:`safe_schedule_threadsafe` wraps the call, closes the coroutine on scheduling failure, and returns ``None`` (instead of a half-formed future) so callers can branch cleanly: fut = safe_schedule_threadsafe(coro, loop) if fut is None: return # or fallback behavior fut.result(timeout=5) The helper deliberately does NOT also handle ``future.result()`` failures — that is a separate concern. Once the loop has accepted the coroutine, its lifecycle belongs to the loop, not the scheduling thread. ) annotationsN)Future)Any CoroutineOptionalz$Failed to schedule coroutine on loop)logger log_message log_levelcoroCoroutine[Any, Any, Any]loop#Optional[asyncio.AbstractEventLoop]rOptional[logging.Logger]r strr intreturnOptional[Future]cz||nt}|Atj|r|||d|dS tj||S#t $rK}tj|r|||d||Yd}~dSd}~wwxYw)aYSchedule ``coro`` on ``loop`` from a sync context, leak-safe. Returns the :class:`concurrent.futures.Future` on success, or ``None`` if the loop is missing or :func:`asyncio.run_coroutine_threadsafe` raised (e.g. the loop was closed during a shutdown race). In all failure paths the coroutine is :meth:`close`-d so it does not trigger ``"coroutine was never awaited"`` warnings or leak its frame. Callers retain full control over what to do with the returned future (call ``.result(timeout=...)``, attach ``add_done_callback``, ignore it fire-and-forget, etc.). Nz%s: loop is Nonez%s: %s)_DEFAULT_LOGGERasyncio iscoroutinecloselogrun_coroutine_threadsafe Exception)r r rr r rexcs 5/home/kuhnn/.hermes/hermes-agent/agent/async_utils.pysafe_schedule_threadsafer"s(&&&OC |  t $ $  JJLLL  -{;;;t/d;;;   t $ $  JJLLL  8[#666ttttt sA%% B:/AB55B:) r r r rrrr rr rrr)__doc__ __future__rrloggingconcurrent.futuresrtypingrrr getLogger__name__rDEBUGrrr)s,#"""""%%%%%%++++++++++$'#H--(,=] """"""""r(