Code Review
/
pti
/
o2.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Fix: INF-253 o2 api failed after too many queries
[pti/o2.git]
/
o2app
/
adapter
/
unit_of_work.py
diff --git
a/o2app/adapter/unit_of_work.py
b/o2app/adapter/unit_of_work.py
index
000d181
..
732216e
100644
(file)
--- a/
o2app/adapter/unit_of_work.py
+++ b/
o2app/adapter/unit_of_work.py
@@
-27,15
+27,21
@@
from o2dms.adapter import dms_repository
from o2common.helper import o2logging
\r
logger = o2logging.get_logger(__name__)
\r
\r
from o2common.helper import o2logging
\r
logger = o2logging.get_logger(__name__)
\r
\r
+
\r
+engine = create_engine(
\r
+ config.get_postgres_uri(),
\r
+ isolation_level="REPEATABLE READ",
\r
+ pool_size=200, max_overflow=0,
\r
+ pool_recycle=3600
\r
+)
\r
+
\r
DEFAULT_SESSION_FACTORY = sessionmaker(
\r
DEFAULT_SESSION_FACTORY = sessionmaker(
\r
- bind=create_engine(
\r
- config.get_postgres_uri(),
\r
- isolation_level="REPEATABLE READ",
\r
- )
\r
+ autocommit=False, autoflush=False, bind=engine
\r
)
\r
\r
\r
class SqlAlchemyUnitOfWork(AbstractUnitOfWork):
\r
)
\r
\r
\r
class SqlAlchemyUnitOfWork(AbstractUnitOfWork):
\r
+
\r
def __init__(self, session_factory=DEFAULT_SESSION_FACTORY):
\r
self.session_factory = session_factory
\r
\r
def __init__(self, session_factory=DEFAULT_SESSION_FACTORY):
\r
self.session_factory = session_factory
\r
\r