fix(signals): Double-check directly provided session ids to ensure they exsist.

ee/hogai/chat_agent/session_summaries/nodes.py

@@ -355,6 +355,20 @@ def _get_session_ids_with_filters(self, replay_filters: RecordingsQuery, limit:
         session_ids = [recording["session_id"] for recording in results.results]
         return session_ids if session_ids else None
 
+    def _validate_specific_session_ids(self, session_ids: list[str]) -> list[str] | None:
+        """Validate that specific session IDs exist in the database."""
+        from posthog.session_recordings.queries.session_replay_events import SessionReplayEvents
+
+        replay_events = SessionReplayEvents()
+        sessions_found, _, _ = replay_events.sessions_found_with_timestamps(
+            session_ids=session_ids,
+            team=self._node._team,
+        )
+        if not sessions_found:
+            return None
+        # Preserve the original order, filtering out invalid sessions
+        return [sid for sid in session_ids if sid in sessions_found]
+
     async def _generate_filter_query(self, plain_text_query: str, config: RunnableConfig) -> str:
         """Generate a filter query for the user's summarization query to keep the search context clear"""
         messages = [
@@ -408,8 +422,13 @@ async def search_sessions(
                 return self._node._create_error_response(self._node._base_error_instructions, state)
             # Use specific session IDs, if provided
             if state.specific_session_ids_to_summarize:
-                # Return session ids right away to use in the next step
-                return state.specific_session_ids_to_summarize
+                # Validate that sessions exist before using them
+                valid_session_ids = await database_sync_to_async(
+                    self._validate_specific_session_ids, thread_sensitive=False
+                )(state.specific_session_ids_to_summarize)
+                if not valid_session_ids:
+                    return None
+                return valid_session_ids
             # Use current filters, if provided
             if state.should_use_current_filters:
                 if not current_filters:

ee/hogai/chat_agent/session_summaries/test/test_nodes.py

@@ -989,3 +989,26 @@ def test_get_session_ids_respects_limit(self) -> None:
         self.assertIsNotNone(session_ids)
         assert session_ids is not None  # Type narrowing for mypy
         self.assertEqual(len(session_ids), 1, "Should return exactly 1 session due to limit")
+
+    @freeze_time("2025-09-03T12:00:00")
+    def test_validate_specific_session_ids_filters_invalid(self) -> None:
+        """Test that invalid session IDs are filtered out while valid ones are kept."""
+        valid_ids = [self.session_id_1, self.session_id_2]
+        invalid_ids = ["nonexistent-session-1", "nonexistent-session-2"]
+        all_ids = valid_ids + invalid_ids
+
+        result = self.node._session_search._validate_specific_session_ids(all_ids)
+
+        self.assertIsNotNone(result)
+        assert result is not None
+        self.assertEqual(len(result), 2)
+        self.assertEqual(result, valid_ids)
+
+    @freeze_time("2025-09-03T12:00:00")
+    def test_validate_specific_session_ids_all_invalid_returns_none(self) -> None:
+        """Test that when all session IDs are invalid, None is returned."""
+        invalid_ids = ["nonexistent-session-1", "nonexistent-session-2"]
+
+        result = self.node._session_search._validate_specific_session_ids(invalid_ids)
+
+        self.assertIsNone(result)