delete reference in registery

AxFoundation · Oct 22, 2020 · 6f5814b · 6f5814b
1 parent 050e71e
commit 6f5814b
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/strax/storage/mongo.py b/strax/storage/mongo.py
@@ -57,6 +57,9 @@ def _read_chunk(self, backend_key, chunk_info, dtype, compressor):
         for i in range(chunk_len):
             for key in np.dtype(dtype).names:
                 result[i][key] = chunk_doc[i][key]
+
+        # We are done with this chunk.
+        del self.chunks_registry[chunk_i]
         return result
 
     def _saver(self, key, metadata):