diff --git a/examples/python/dynamic_steps_example.py b/examples/python/dynamic_steps_example.py index 4422dd39d..75881c5be 100644 --- a/examples/python/dynamic_steps_example.py +++ b/examples/python/dynamic_steps_example.py @@ -204,4 +204,9 @@ if __name__ == "__main__": "retriever": retrieve, } - asyncio.run(main(steps_to_enable)) + loop = asyncio.new_event_loop() + asyncio.set_event_loop(loop) + try: + loop.run_until_complete(main(steps_to_enable)) + finally: + loop.run_until_complete(loop.shutdown_asyncgens())