I have created a custom node

PPujari12

I have created a custom node_postprocessor and passed it as an argument in the Query engine as -
query_engine = RetrieverQueryEngine.from_args(retriever, node_postprocessors=[postprocessor])
however, while doing query to the engine I am getting this error -
RuntimeError Traceback (most recent call last)
<ipython-input-51-cc65093c9740> in <cell line: 1>()
----> 1 response = query_engine.query(
2 "is sarthak a good boy"
3 )

22 frames
/usr/lib/python3.10/asyncio/runners.py in run(main, debug)
31 """
32 if events._get_running_loop() is not None:
---> 33 raise RuntimeError(
34 "asyncio.run() cannot be called from a running event loop")
35

RuntimeError: asyncio.run() cannot be called from a running event loop

6 comments

ssansmoraxz

can you share the code fragment you tried this with?

ssansmoraxz

there seems to be some problematic code somewhere.

LLogan M

Just need to add to your code

Plain Text

import nest_asyncio
nest_asyncio.apply()

ssansmoraxz

ok that works too.

ssansmoraxz

my original idea was creating async tasks in the current event loop if exists otherwise create a new one. then wait and fetch the results.

LLogan M

I think it will still be an issue, anytime you are using asyncio.run() in a running event loop 🤔

Add a reply

Find answers from the community

I have created a custom node_