Delete cache records for deleted items

zopefoundation · Aug 12, 2014 · 835ed59 · 835ed59
1 parent c5c39ea
commit 835ed59
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/src/mongopersist/datamanager.py b/src/mongopersist/datamanager.py
@@ -316,6 +316,8 @@ def remove(self, obj):
         # Now we remove the object from Mongo.
         coll = self.get_collection_from_object(obj)
         coll.remove({'_id': obj._p_oid.id})
+        if hash(obj._p_oid) in self._object_cache:
+            del self._object_cache[hash(obj._p_oid)]
         # Edge case: The object was just added in this transaction.
         if id(obj) in self._inserted_objects:
             # but it still had to be removed from mongo, because insert