Use as an OpenAleph service

ftm-geocode can be used as an OpenAleph service to geocode ingested entities.

Refer to the openaleph-procrastinate documentation about the service, task queue and worker logic.

Run the worker

export PROCRASTINATE_APP=ftm_geocode.tasks.app
procrastinate worker -q ftm-geocode

Defer tasks from other services

from followthemoney.entity import EntityProxy

from openaleph_procrastinate.app import make_app
from openaleph_procrastinate.model import DatasetJob

app = make_app(__loader__.name)

def defer_geocode_job(entity: EntityProxy):
    with app.open():
        job = DatasetJob.from_entity(
            dataset="my_dataset",
            queue="ftm-geocode",
            task="ftm_geocode.tasks.geocode",
            entity=entity
        )
        job.defer(app=app)