equal
deleted
inserted
replaced
263 eid = self.extid2eid(str(extid), etype, session, |
263 eid = self.extid2eid(str(extid), etype, session, |
264 insert=False) |
264 insert=False) |
265 # entity has been deleted from external repository but is not known here |
265 # entity has been deleted from external repository but is not known here |
266 if eid is not None: |
266 if eid is not None: |
267 entity = session.entity_from_eid(eid, etype) |
267 entity = session.entity_from_eid(eid, etype) |
268 repo.delete_info(session, entity, self.uri, extid) |
268 repo.delete_info(session, entity, self.uri, extid, |
|
269 scleanup=True) |
269 except: |
270 except: |
270 self.exception('while updating %s with external id %s of source %s', |
271 self.exception('while updating %s with external id %s of source %s', |
271 etype, extid, self.uri) |
272 etype, extid, self.uri) |
272 continue |
273 continue |
273 session.execute('SET X value %(v)s WHERE X pkey %(k)s', |
274 session.execute('SET X value %(v)s WHERE X pkey %(k)s', |