Every job gets an id and a state machine: queued, running, retry, published. Deduplicate by job id before writing a publication record.

Related