@@ -185,18 +185,19 @@ async def handle_signalr_open(self) -> None:
185185 data = response .json ()
186186 session_id = data ["sessionId" ]
187187 message = data ["message" ]
188- logger .info (f"Received message from UiPath MCP: { message } " )
189- if session_id not in self .session_servers :
190- # Create and start a new session server
191- session_server = SessionServer (self .server , session_id )
192- self .session_servers [session_id ] = session_server
193- await session_server .start (self .signalr_client )
194-
195- # Get the session server for this session
196- session_server = self .session_servers [session_id ]
197-
198- # Forward the message to the session's MCP server
199- await session_server .send_message (message )
188+ logger .info (f"Received message from UiPath MCP: { data } " )
189+ if session_id :
190+ if session_id not in self .session_servers :
191+ # Create and start a new session server
192+ session_server = SessionServer (self .server , session_id )
193+ self .session_servers [session_id ] = session_server
194+ await session_server .start (self .signalr_client )
195+
196+ # Get the session server for this session
197+ session_server = self .session_servers [session_id ]
198+
199+ # Forward the message to the session's MCP server
200+ await session_server .send_message (message )
200201
201202 async def handle_signalr_close (self ) -> None :
202203 """Handle SignalR connection close event."""
0 commit comments