Method _invoke_graph

runner/task_runner.py:152–167

(self, graph: Any, state: Any, recursion_limit: int)

        return "failed"

    def _invoke_graph(self, graph: Any, state: Any, recursion_limit: int) -> Any:
        try:
            import nest_asyncio

            nest_asyncio.apply()
        except ImportError:
            pass

        coro = graph.ainvoke(state, config={"recursion_limit": recursion_limit})
        try:
            return asyncio.run(coro)
        except RuntimeError as exc:
            if "asyncio.run() cannot be called from a running event loop" not in str(exc):
                raise
            loop = asyncio.get_event_loop()
            return loop.run_until_complete(coro)