1 files changed, 10 insertions, 2 deletions
diff --git a/lib/sqlalchemy/engine/util.py b/lib/sqlalchemy/engine/util.py
index 213485cc9..529b2ca73 100644
--- a/lib/sqlalchemy/engine/util.py
+++ b/lib/sqlalchemy/engine/util.py
@@ -10,11 +10,13 @@ from __future__ import annotations
 import typing
 from typing import Any
 from typing import Callable
+from typing import Optional
 from typing import TypeVar
 
 from .. import exc
 from .. import util
 from ..util._has_cy import HAS_CYEXTENSION
+from ..util.typing import Protocol
 
 if typing.TYPE_CHECKING or not HAS_CYEXTENSION:
     from ._py_util import _distill_params_20 as _distill_params_20
@@ -49,6 +51,10 @@ def connection_memoize(key: str) -> Callable[[_C], _C]:
     return decorated  # type: ignore[return-value]
 
 
+class _TConsSubject(Protocol):
+    _trans_context_manager: Optional[TransactionalContext]
+
+
 class TransactionalContext:
     """Apply Python context manager behavior to transaction objects.
 
@@ -59,6 +65,8 @@ class TransactionalContext:
 
     __slots__ = ("_outer_trans_ctx", "_trans_subject", "__weakref__")
 
+    _trans_subject: Optional[_TConsSubject]
+
     def _transaction_is_active(self) -> bool:
         raise NotImplementedError()
 
@@ -82,7 +90,7 @@ class TransactionalContext:
         """
         raise NotImplementedError()
 
-    def _get_subject(self) -> Any:
+    def _get_subject(self) -> _TConsSubject:
         raise NotImplementedError()
 
     def commit(self) -> None:
@@ -95,7 +103,7 @@ class TransactionalContext:
         raise NotImplementedError()
 
     @classmethod
-    def _trans_ctx_check(cls, subject: Any) -> None:
+    def _trans_ctx_check(cls, subject: _TConsSubject) -> None:
         trans_context = subject._trans_context_manager
         if trans_context:
             if not trans_context._transaction_is_active():