diff options
| author | mike bayer <mike_mp@zzzcomputing.com> | 2020-12-08 18:04:25 +0000 |
|---|---|---|
| committer | Gerrit Code Review <gerrit@bbpush.zzzcomputing.com> | 2020-12-08 18:04:25 +0000 |
| commit | c5831b1abd98c46ef7eab7ee82ead18756aea112 (patch) | |
| tree | 4699cf11577807337e92edb197c8a52b4d5969af /lib/sqlalchemy/ext | |
| parent | 18b1b261ff988549e75b011f2f4296fb13b24d64 (diff) | |
| parent | 76d90152302461637cfecb6c0cac65a50975c570 (diff) | |
| download | sqlalchemy-c5831b1abd98c46ef7eab7ee82ead18756aea112.tar.gz | |
Merge "Detect non compatible execution in async mode"
Diffstat (limited to 'lib/sqlalchemy/ext')
| -rw-r--r-- | lib/sqlalchemy/ext/asyncio/engine.py | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/lib/sqlalchemy/ext/asyncio/engine.py b/lib/sqlalchemy/ext/asyncio/engine.py index 9e4851dfc..16edcc2b2 100644 --- a/lib/sqlalchemy/ext/asyncio/engine.py +++ b/lib/sqlalchemy/ext/asyncio/engine.py @@ -243,6 +243,7 @@ class AsyncConnection(StartableContext, AsyncConnectable): statement, parameters, execution_options, + _require_await=True, ) if result.context._is_server_side: raise async_exc.AsyncMethodRequired( @@ -272,6 +273,7 @@ class AsyncConnection(StartableContext, AsyncConnectable): util.EMPTY_DICT.merge_with( execution_options, {"stream_results": True} ), + _require_await=True, ) if not result.context._is_server_side: # TODO: real exception here @@ -322,6 +324,7 @@ class AsyncConnection(StartableContext, AsyncConnectable): statement, parameters, execution_options, + _require_await=True, ) if result.context._is_server_side: raise async_exc.AsyncMethodRequired( |