from .unitofwork import UOWTransaction
from .. import engine
from .. import exc as sa_exc
-from .. import future
from .. import sql
from .. import util
from ..inspection import inspect
"_compile_state_cls",
"_starting_event_idx",
"_events_todo",
- "_future",
"_update_execution_options",
)
bind_arguments,
compile_state_cls,
events_todo,
- future,
):
self.session = session
self.statement = statement
self.bind_arguments = bind_arguments
self._compile_state_cls = compile_state_cls
self._events_todo = list(events_todo)
- self._future = future
def _remaining_events(self):
return self._events_todo[self._starting_event_idx + 1 :]
elif not bind_arguments:
bind_arguments = {}
- if future and (
+ if (
statement._propagate_attrs.get("compile_state_plugin", None)
== "orm"
):
bind_arguments,
compile_state_cls,
events_todo,
- future,
)
for idx, fn in enumerate(events_todo):
orm_exec_state._starting_event_idx = idx
with_for_update = query.ForUpdateArg._from_argument(with_for_update)
- stmt = future.select(object_mapper(instance))
+ stmt = sql.select(object_mapper(instance))
if (
loading.load_on_ident(
self,