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()