Function ameth

src/structlog/_native.py:176–199

.. versionchanged:: 23.3.0 Callsite parameters are now also collected under asyncio.

(self: Any, event: str, *args: Any, **kw: Any)

            )

        async def ameth(self: Any, event: str, *args: Any, **kw: Any) -> Any:
            """
            .. versionchanged:: 23.3.0
               Callsite parameters are now also collected under asyncio.
            """
            event = _maybe_interpolate(event, args)

            # Capture thread-specific info before handing off to the executor.
            thread_token = _ASYNC_CALLING_THREAD.set(
                (threading.get_ident(), threading.current_thread().name)
            )
            scs_token = _ASYNC_CALLING_STACK.set(sys._getframe().f_back)  # type: ignore[arg-type]
            ctx = contextvars.copy_context()

            try:
                await asyncio.get_running_loop().run_in_executor(
                    None,
                    lambda: ctx.run(
                        lambda: self._proxy_to_logger(name, event, **kw)
                    ),
                )
            finally:
                _ASYNC_CALLING_STACK.reset(scs_token)
                _ASYNC_CALLING_THREAD.reset(thread_token)

        meth.__name__ = name
        ameth.__name__ = f"a{name}"