server/sources/datafeed.py
branchstable
changeset 7708 45be3a9debe6
parent 7699 d07cde311630
child 7727 70ea754d3e04
--- a/server/sources/datafeed.py	Wed Jul 27 14:22:32 2011 +0200
+++ b/server/sources/datafeed.py	Wed Jul 27 14:24:40 2011 +0200
@@ -147,6 +147,7 @@
         return True
 
     def release_synchronization_lock(self, session):
+        session.set_cnxset()
         session.execute('SET X synchronizing FALSE WHERE X eid %(x)s',
                         {'x': self.eid})
         session.commit()
@@ -276,7 +277,7 @@
         sourceparams['parser'] = self
         try:
             eid = session.repo.extid2eid(source, str(uri), etype, session,
-                                         complete=False,
+                                         complete=False, commit=False,
                                          sourceparams=sourceparams)
         except ValidationError, ex:
             self.source.error('error while creating %s: %s', etype, ex)