268 def source_cwuris(self, session): |
268 def source_cwuris(self, session): |
269 sql = ('SELECT extid, eid, type FROM entities, cw_source_relation ' |
269 sql = ('SELECT extid, eid, type FROM entities, cw_source_relation ' |
270 'WHERE entities.eid=cw_source_relation.eid_from ' |
270 'WHERE entities.eid=cw_source_relation.eid_from ' |
271 'AND cw_source_relation.eid_to=%s' % self.eid) |
271 'AND cw_source_relation.eid_to=%s' % self.eid) |
272 return dict((b64decode(uri), (eid, type)) |
272 return dict((b64decode(uri), (eid, type)) |
273 for uri, eid, type in session.system_sql(sql)) |
273 for uri, eid, type in session.system_sql(sql).fetchall()) |
274 |
274 |
275 def init_import_log(self, session, **kwargs): |
275 def init_import_log(self, session, **kwargs): |
276 dataimport = session.create_entity('CWDataImport', cw_import_of=self, |
276 dataimport = session.create_entity('CWDataImport', cw_import_of=self, |
277 start_timestamp=datetime.utcnow(), |
277 start_timestamp=datetime.utcnow(), |
278 **kwargs) |
278 **kwargs) |