From ed4a23d104711e24adfe9133743ca990feaf6556 Mon Sep 17 00:00:00 2001
From: Erik Montnemery <erik@montnemery.com>
Date: Mon, 14 Jul 2025 20:57:00 +0200
Subject: [PATCH] Override connect method in RecorderPool (#148490)

---
 homeassistant/components/recorder/pool.py | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git a/homeassistant/components/recorder/pool.py b/homeassistant/components/recorder/pool.py
index d8d7ddb832a..2ee41ba2038 100644
--- a/homeassistant/components/recorder/pool.py
+++ b/homeassistant/components/recorder/pool.py
@@ -12,6 +12,7 @@ from sqlalchemy.exc import SQLAlchemyError
 from sqlalchemy.pool import (
     ConnectionPoolEntry,
     NullPool,
+    PoolProxiedConnection,
     SingletonThreadPool,
     StaticPool,
 )
@@ -119,6 +120,12 @@ class RecorderPool(SingletonThreadPool, NullPool):
         )
         return NullPool._create_connection(self)  # noqa: SLF001
 
+    def connect(self) -> PoolProxiedConnection:
+        """Return a connection from the pool."""
+        if threading.get_ident() in self.recorder_and_worker_thread_ids:
+            return super().connect()
+        return NullPool.connect(self)
+
 
 class MutexPool(StaticPool):
     """A pool which prevents concurrent accesses from multiple threads.