1420 if server.DEBUG & server.DBG_REPO: |
1420 if server.DEBUG & server.DBG_REPO: |
1421 print 'DELETE entities', etype, [entity.eid for entity in entities] |
1421 print 'DELETE entities', etype, [entity.eid for entity in entities] |
1422 source = self.sources_by_uri[sourceuri] |
1422 source = self.sources_by_uri[sourceuri] |
1423 if source.should_call_hooks: |
1423 if source.should_call_hooks: |
1424 self.hm.call_hooks('before_delete_entity', session, entities=entities) |
1424 self.hm.call_hooks('before_delete_entity', session, entities=entities) |
1425 self._delete_info_multi(session, entities, sourceuri) |
1425 if session.deleted_in_transaction(source.eid): |
|
1426 # source is being deleted, think to give scleanup argument |
|
1427 self._delete_info_multi(session, entities, sourceuri, scleanup=source.eid) |
|
1428 else: |
|
1429 self._delete_info_multi(session, entities, sourceuri) |
1426 source.delete_entities(session, entities) |
1430 source.delete_entities(session, entities) |
1427 if source.should_call_hooks: |
1431 if source.should_call_hooks: |
1428 self.hm.call_hooks('after_delete_entity', session, entities=entities) |
1432 self.hm.call_hooks('after_delete_entity', session, entities=entities) |
1429 # don't clear cache here, it is done in a hook on commit |
1433 # don't clear cache here, it is done in a hook on commit |
1430 |
1434 |