199 importlog = self.init_import_log(session) |
199 importlog = self.init_import_log(session) |
200 parser = self._get_parser(session, sourceuris=myuris, import_log=importlog) |
200 parser = self._get_parser(session, sourceuris=myuris, import_log=importlog) |
201 if self.process_urls(parser, self.urls, raise_on_error): |
201 if self.process_urls(parser, self.urls, raise_on_error): |
202 self.warning("some error occured, don't attempt to delete entities") |
202 self.warning("some error occured, don't attempt to delete entities") |
203 elif self.config['delete-entities'] and myuris: |
203 elif self.config['delete-entities'] and myuris: |
|
204 byetype = {} |
204 for extid, (eid, etype) in myuris.iteritems(): |
205 for extid, (eid, etype) in myuris.iteritems(): |
205 if parser.is_deleted(extid, etype, eid): |
206 if parser.is_deleted(extid, etype, eid): |
206 byetype.setdefault(etype, []).append(str(eid)) |
207 byetype.setdefault(etype, []).append(str(eid)) |
207 for etype, eids in byetype.iteritems(): |
208 for etype, eids in byetype.iteritems(): |
208 self.warning('delete %s %s entities', len(eids), etype) |
209 self.warning('delete %s %s entities', len(eids), etype) |