equal
deleted
inserted
replaced
255 insert=False) |
255 insert=False) |
256 # entity has been deleted from external repository but is not known here |
256 # entity has been deleted from external repository but is not known here |
257 if eid is not None: |
257 if eid is not None: |
258 entity = session.entity_from_eid(eid, etype) |
258 entity = session.entity_from_eid(eid, etype) |
259 repo.delete_info(session, entity, self.uri, extid, |
259 repo.delete_info(session, entity, self.uri, extid, |
260 scleanup=True) |
260 scleanup=self.eid) |
261 except: |
261 except: |
262 self.exception('while updating %s with external id %s of source %s', |
262 self.exception('while updating %s with external id %s of source %s', |
263 etype, extid, self.uri) |
263 etype, extid, self.uri) |
264 continue |
264 continue |
265 session.execute('SET X value %(v)s WHERE X pkey %(k)s', |
265 session.execute('SET X value %(v)s WHERE X pkey %(k)s', |