fix: windows execution

Author: cosmyo

packages/uipath-openai-agents/src/uipath_openai_agents/runtime/runtime.py

@@ -61,7 +61,6 @@ def __init__(
         self.storage_path: str | None = storage_path
         self.loaded_object: Any | None = loaded_object
         self.storage: SqliteAgentStorage | None = storage
-        self._session: SQLiteSession | None = None
 
         # Configure OpenAI Agents SDK to use Responses API
         # UiPath supports both APIs via X-UiPath-LlmGateway-ApiFlavor header
@@ -210,38 +209,32 @@ async def _run_agent(
         agent_input = self._prepare_agent_input(input)
         is_resuming = bool(options and options.resume)
 
-        # Get or create session for state persistence
-        # Close any existing session before creating a new one
-        if self._session:
-            self._session.close()
-            self._session = None
-
+        # Create session for state persistence (local to this run)
         # SQLiteSession automatically loads existing data from the database when created
+        session: SQLiteSession | None = None
         if self.storage_path:
-            self._session = SQLiteSession(self.runtime_id, self.storage_path)
-        else:
-            self._session = None
+            session = SQLiteSession(self.runtime_id, self.storage_path)
 
         # Run the agent with streaming if events requested
         try:
             if stream_events:
                 # Use streaming for events
                 async for event_or_result in self._run_agent_streamed(
-                    agent_input, options, stream_events
+                    agent_input, options, stream_events, session
                 ):
                     yield event_or_result
             else:
                 # Use non-streaming for simple execution
                 result = await Runner.run(
                     starting_agent=self.agent,
                     input=agent_input,
-                    session=self._session,
+                    session=session,
                 )
                 yield self._create_success_result(result.final_output)
 
         except Exception:
             # Clean up session on error
-            if self._session and self.storage_path and not is_resuming:
+            if session and self.storage_path and not is_resuming:
                 # Delete incomplete session
                 try:
                     import os
@@ -251,12 +244,17 @@ async def _run_agent(
                 except Exception:
                     pass  # Best effort cleanup
             raise
+        finally:
+            # Always close session after run completes
+            if session:
+                session.close()
 
     async def _run_agent_streamed(
         self,
         agent_input: str | list[Any],
         options: UiPathExecuteOptions | UiPathStreamOptions | None,
         stream_events: bool,
+        session: SQLiteSession | None,
     ) -> AsyncGenerator[UiPathRuntimeEvent | UiPathRuntimeResult, None]:
         """
         Run agent using streaming API to enable event streaming.
@@ -274,7 +272,7 @@ async def _run_agent_streamed(
         result = Runner.run_streamed(
             starting_agent=self.agent,
             input=agent_input,
-            session=self._session,
+            session=session,
         )
 
         # Stream events from the agent
@@ -492,10 +490,6 @@ async def get_schema(self) -> UiPathRuntimeSchema:
 
     async def dispose(self) -> None:
         """Cleanup runtime resources."""
-        # Close OpenAI Agents SDK session if it exists
-        if self._session:
-            self._session.close()
-            self._session = None
-
+        # Sessions are closed immediately after each run in _run_agent()
         # Storage is shared across runtimes and managed by the factory
-        # Do not dispose it here
+        pass