web / lib/jobs/workflows/ingest-process

lib/jobs/workflows/ingest-process

Post-review ingest processing workflow.

Queued after a user resolves a NEEDS_REVIEW state on an IngestJob. Supports resuming from different points depending on the review reason:

detect-schema: re-runs detect-schema → validate → create-version → geocode → create-events
create-schema-version (default): create-version → geocode → create-events
create-events: only create-events (e.g. after geocoding partial approval)

Tasks throw on error — since there’s no Promise.allSettled here, errors propagate to Payload’s top-level handler which calls onFail. try/finally ensures updateIngestFileStatusForJob runs even on failure.

Variables

ingestProcessWorkflow

const ingestProcessWorkflow: WorkflowConfig<"ingest-process">