Use synchronous Runner.run_sync and call agent directly from the orchestrator

Author: AnatoliB

samples-v2/openai_agents/basic/hello_world.py

@@ -2,19 +2,21 @@
 
 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)
 
-async def main():
+def main():
     agent = Agent(
         name="Assistant",
         instructions="You only respond in haikus.",
     )
 
-    result = await Runner.run(agent, "Tell me about recursion in programming.")
+    result = Runner.run_sync(agent, "Tell me about recursion in programming.")
     return result.final_output
     # Function calls itself,
     # Looping in smaller pieces,
     # Endless by design.
-
-
-if __name__ == "__main__":
-    asyncio.run(main())

samples-v2/openai_agents/function_app.py

@@ -1,6 +1,7 @@
 import azure.functions as func
 import logging
 
+
 app = func.FunctionApp(http_auth_level=func.AuthLevel.FUNCTION)
 
 @app.route(route="orchestrators/{functionName}")
@@ -14,16 +15,7 @@ async def hello_orchestration_starter(req: func.HttpRequest, client):
 
 @app.orchestration_trigger(context_name="context")
 def basic_hello_world_orchestrator(context):
-    result = yield context.call_activity("openai_agent_activity")
-    return result
-
-# Activity for OpenAI agent execution
-@app.activity_trigger(input_name="input")
-async def openai_agent_activity(input: str):
-    # TODO: Instead of wrapping this code in an activity function like this,
-    # we should be able to invoke it from the orchestrator directly.
-    # In order to enable this, Runner.run invocations should be implicitly
-    # wrapped in activity invocations. 
     from basic.hello_world import main
-    result = await main()
+    result = main()
     return result
+