🐛 (manager) Fix emitted store

Author: simonwoerpel

ingestors/manager.py

@@ -7,7 +7,7 @@
 
 import magic
 from banal import ensure_list
-from followthemoney import model
+from followthemoney import StatementEntity, model
 from followthemoney.helpers import entity_filename
 from followthemoney.namespace import Namespace
 from ftmq.store.fragments import get_fragments
@@ -140,7 +140,7 @@ def emit_entity(self, entity, fragment=None):
         entity = self.ns.apply(entity)
         self.writer.put(entity.to_dict(), fragment)
         with self.emitted.writer() as bulk:
-            bulk.add_entity(make_checksum_entity(entity, quiet=True))
+            bulk.add_entity(make_checksum_entity(entity, StatementEntity, quiet=True))
 
     def emit_text_fragment(self, entity, texts, fragment):
         texts = [t for t in ensure_list(texts) if filter_text(t)]

poetry.lock

@@ -70,7 +70,7 @@ normality==3.0.2 ; python_version >= "3.11" and python_version < "3.14"
 numpy==2.3.4 ; python_version >= "3.11" and python_version < "3.14"
 odfpy==1.4.1 ; python_version >= "3.11" and python_version < "3.14"
 olefile==0.46 ; python_version >= "3.11" and python_version < "3.14"
-openaleph-procrastinate @ git+https://github.com/openaleph/openaleph-procrastinate.git@2d19b710f029e5409f03ca0e993c400d359fe1c9 ; python_version >= "3.11" and python_version < "3.14"
+openaleph-procrastinate @ git+https://github.com/openaleph/openaleph-procrastinate.git@1f109d3f2eb292d0e2e909fc5a2312448427f676 ; python_version >= "3.11" and python_version < "3.14"
 openaleph-servicelayer==1.23.3 ; python_version >= "3.11" and python_version < "3.14"
 openpyxl==3.1.5 ; python_version >= "3.11" and python_version < "3.14"
 orjson==3.11.3 ; python_version >= "3.11" and python_version < "3.14"

requirements.txt

@@ -6,7 +6,9 @@
 import unittest
 from tempfile import mkdtemp
 
+from followthemoney import StatementEntity
 from ftmq.store.fragments import get_fragments
+from openaleph_procrastinate.util import make_checksum_entity
 from procrastinate.testing import InMemoryConnector
 from servicelayer import settings as sls
 from servicelayer.archive.util import ensure_path
@@ -21,6 +23,8 @@
 def emit_entity(self, entity, fragment=None):
     self.entities.append(entity)
     self.writer.put(entity.to_dict(), fragment=fragment)
+    with self.emitted.writer() as bulk:
+        bulk.add_entity(make_checksum_entity(entity, StatementEntity, quiet=True))
 
 
 class TestCase(unittest.TestCase):