Function run_in_thread

scrapy/utils/asyncio.py:296–313

Call a function in a thread and return its result as a coroutine. This uses either :func:`asyncio.to_thread` or :func:`twisted.internet.threads.deferToThread`, depending on whether asyncio support is available. .. versionadded:: 2.15.0

(
    func: Callable[_P, _T], *args: _P.args, **kwargs: _P.kwargs
)

async def run_in_thread(
    func: Callable[_P, _T], *args: _P.args, **kwargs: _P.kwargs
) -> _T:
    """Call a function in a thread and return its result as a coroutine.

    This uses either :func:`asyncio.to_thread` or
    :func:`twisted.internet.threads.deferToThread`, depending on whether
    asyncio support is available.

    .. versionadded:: 2.15.0
    """
    if is_asyncio_available():
        return await asyncio.to_thread(func, *args, **kwargs)

    # circular import
    from scrapy.utils.defer import maybe_deferred_to_future  # noqa: PLC0415

    return await maybe_deferred_to_future(deferToThread(func, *args, **kwargs))