bekasikab@pospbb:~/domains/api-pbb.bekasikab.opensipkd.com/apps/base$ git diff
diff --git a/opensipkd/base/scripts/import_log.py b/opensipkd/base/scripts/import_log.py
index d67d5ab..dce5b0f 100644
--- a/opensipkd/base/scripts/import_log.py
+++ b/opensipkd/base/scripts/import_log.py
@@ -1,7 +1,6 @@
import sys
from datetime import datetime
-
-# import transaction
+import transaction
from opensipkd.base import Base, DBSession
from pyramid.paster import setup_logging, get_appsettings
from sqlalchemy import engine_from_config
@@ -58,11 +57,10 @@ def main(argv=sys.argv):
level=level,
logger=lg,
msg=msg)
- LogDBSession.add(row)
- LogDBSession.flush()
+ with transaction.manager:
+ LogDBSession.add(row)
else:
if l.find('waitress.queue') > 0:
pass
else:
print(l)
- LogDBSession.commit()