✨ Add ftm-translate service to queues

Author: simonwoerpel

openaleph_procrastinate/defer.py

@@ -310,7 +310,7 @@ def transcribe(
 ) -> None:
     """
     Defer a new job for `ftm-transcribe`
-    It will only deferred if `OPENALEPH_TRANSCRIBE_DEFER=1` (the default)
+    It will only deferred if `OPENALEPH_TRANSCRIBE_DEFER=1` (the default is not)
 
     Args:
         app: The procrastinate app instance
@@ -331,6 +331,32 @@ def transcribe(
         job.defer(app, priority)
 
 
+def translate(
+    app: App, dataset: str, entities: Iterable[EntityProxy], **context: Any
+) -> None:
+    """
+    Defer a new job for `ftm-translate`
+    It will only deferred if `OPENALEPH_TRANSLATE_DEFER=1` (the default is not)
+
+    Args:
+        app: The procrastinate app instance
+        dataset: The ftm dataset or collection
+        entities: The file entities to ingest
+        context: Additional job context
+    """
+    if tasks.translate.defer:
+        job = DatasetJob.from_entities(
+            dataset=dataset,
+            queue=tasks.translate.queue,
+            task=tasks.translate.task,
+            entities=entities,
+            dehydrate=True,
+            **context,
+        )
+        priority = get_priority(context, tasks.translate.get_priority())
+        job.defer(app, priority)
+
+
 def geocode(
     app: App, dataset: str, entities: Iterable[EntityProxy], **context: Any
 ) -> None:

openaleph_procrastinate/settings.py

@@ -85,6 +85,11 @@ class DeferSettings(BaseSettings):
     )
     """ftm-transcribe"""
 
+    translate: ServiceSettings = ServiceSettings(
+        queue="translate", task="ftm_translate.tasks.translate", defer=False
+    )
+    """ftm-translate"""
+
     geocode: ServiceSettings = ServiceSettings(
         queue="geocode", task="ftm_geocode.tasks.geocode", defer=False
     )