🩹 (manager) Make sure to instantiate a new MemoryStore for every cycle

Author: simonwoerpel

ingestors/manager.py

@@ -10,9 +10,9 @@
 from followthemoney import model
 from followthemoney.helpers import entity_filename
 from followthemoney.namespace import Namespace
-from ftmq.store import get_store
 from ftmq.store.fragments import get_fragments
 from ftmq.store.fragments.utils import safe_fragment
+from ftmq.store.memory import MemoryStore
 from normality import stringify
 from openaleph_procrastinate import defer
 from openaleph_procrastinate.app import App
@@ -107,7 +107,7 @@ def __init__(self, app: App, dataset: str, context: dict[str, Any]):
         self.context = context
         self.ns = Namespace(self.context["namespace"])
         self.work_path = ensure_path(mkdtemp(prefix="ingestor-"))
-        self.emitted = get_store("memory://")
+        self.emitted = MemoryStore()
         self.archive = get_archive()
 
     def make_entity(self, schema, parent=None):