diff options
| author | Morgan McClure <mcclurem@quagmire> | 2015-06-13 19:27:55 -0700 |
|---|---|---|
| committer | Morgan McClure <mcclurem@quagmire> | 2015-06-13 19:27:55 -0700 |
| commit | a8c6cce404caf4a9c20faefc8f11a3e37db3ea05 (patch) | |
| tree | 99f5e1d29daeedaee48e5f5fbcedbb229c1aeef4 /lib/sqlalchemy/orm/query.py | |
| parent | 235165d54618031f525f029e5686a03c273a7c7e (diff) | |
| download | sqlalchemy-pr/182.tar.gz | |
Added max_row_buffer attribute to the context execution options and usepr/182
it to prevent excess memory usage with yield_per
Diffstat (limited to 'lib/sqlalchemy/orm/query.py')
| -rw-r--r-- | lib/sqlalchemy/orm/query.py | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/lib/sqlalchemy/orm/query.py b/lib/sqlalchemy/orm/query.py index 4f8c86a14..8b3df08e7 100644 --- a/lib/sqlalchemy/orm/query.py +++ b/lib/sqlalchemy/orm/query.py @@ -756,7 +756,8 @@ class Query(object): """ self._yield_per = count self._execution_options = self._execution_options.union( - {"stream_results": True}) + {"stream_results": True, + "max_row_buffer": count}) def get(self, ident): """Return an instance based on the given primary key identifier, |