Ingestion Pipleline error: BaseExtractor.aprocess_node was never await #11752
Replies: 1 comment
-
Hey there, @kakarottoxue! Good to see you running into challenges and reaching out. Let's tackle this together. From the context provided, it seems like you're encountering a The Here's a simple example of how to correctly call an async function: async def main():
result = await BaseExtractor.aprocess_node(node) In this example, If you're calling import asyncio
def sync_function(node):
loop = asyncio.get_event_loop()
result = loop.run_until_complete(BaseExtractor.aprocess_node(node)) In this example, Please ensure that you're correctly using the For more information on how to work with async functions in Python, you can refer to the Python asyncio documentation. I hope this helps! If you have any more questions, feel free to ask. Sources
|
Beta Was this translation helpful? Give feedback.
-
Has somebody met this problem? I can't create the ingestion pipeline for this reason
Beta Was this translation helpful? Give feedback.
All reactions