257 call_hooks('before_add_relation', session, |
257 call_hooks('before_add_relation', session, |
258 eidfrom=entity.eid, rtype=attr, eidto=value) |
258 eidfrom=entity.eid, rtype=attr, eidto=value) |
259 call_hooks('after_add_relation', session, |
259 call_hooks('after_add_relation', session, |
260 eidfrom=entity.eid, rtype=attr, eidto=value) |
260 eidfrom=entity.eid, rtype=attr, eidto=value) |
261 |
261 |
262 def source_cwuris(self, session): |
262 def source_cwuris(self, cnx): |
263 sql = ('SELECT extid, eid, type FROM entities, cw_source_relation ' |
263 sql = ('SELECT extid, eid, type FROM entities, cw_source_relation ' |
264 'WHERE entities.eid=cw_source_relation.eid_from ' |
264 'WHERE entities.eid=cw_source_relation.eid_from ' |
265 'AND cw_source_relation.eid_to=%s' % self.eid) |
265 'AND cw_source_relation.eid_to=%s' % self.eid) |
266 return dict((b64decode(uri), (eid, type)) |
266 return dict((b64decode(uri), (eid, type)) |
267 for uri, eid, type in session.system_sql(sql).fetchall()) |
267 for uri, eid, type in cnx.system_sql(sql).fetchall()) |
268 |
268 |
269 def init_import_log(self, session, **kwargs): |
269 def init_import_log(self, session, **kwargs): |
270 dataimport = session.create_entity('CWDataImport', cw_import_of=self, |
270 dataimport = session.create_entity('CWDataImport', cw_import_of=self, |
271 start_timestamp=datetime.utcnow(), |
271 start_timestamp=datetime.utcnow(), |
272 **kwargs) |
272 **kwargs) |