Refactor event loop management: move ensure_event_loop to its own module and clean up imports in hello_world and function_app

Author: AnatoliB

samples-v2/openai_agents/basic/hello_world.py

@@ -1,13 +1,5 @@
-import asyncio
-
 from agents import Agent, Runner
-
-# Ensure event loop is created
-try:
-    asyncio.get_running_loop()
-except RuntimeError:
-    loop = asyncio.new_event_loop()
-    asyncio.set_event_loop(loop)
+import event_loop
 
 def main():
     agent = Agent(

samples-v2/openai_agents/event_loop.py

@@ -0,0 +1,16 @@
+import asyncio
+
+
+def ensure_event_loop():
+    """
+    Ensure an event loop is available for sync execution context.
+    
+    This is necessary when calling Runner.run_sync from Azure Functions
+    Durable orchestrators, which run in a synchronous context but need
+    an event loop for internal async operations.
+    """
+    try:
+        asyncio.get_running_loop()
+    except RuntimeError:
+        loop = asyncio.new_event_loop()
+        asyncio.set_event_loop(loop)

samples-v2/openai_agents/function_app.py

@@ -5,6 +5,8 @@
 from yield_exception import YieldException
 from activity_call_tracker import ActivityCallTracker
 from model_invoker import ModelInvoker, ActivityModelInput
+import event_loop
+
 
 app = func.FunctionApp(http_auth_level=func.AuthLevel.FUNCTION)
 
@@ -19,6 +21,7 @@ async def orchestration_starter(req: func.HttpRequest, client):
 
 @app.orchestration_trigger(context_name="context")
 def basic_hello_world_orchestrator(context):
+    event_loop.ensure_event_loop()
     activity_call_tracker = ActivityCallTracker(context)
     durable_openai_runner = DurableOpenAIRunner(activity_call_tracker=activity_call_tracker)
     set_default_agent_runner(durable_openai_runner)