Every database statement, one function each, as raw SQL.

All functions take the repo explicitly. The complete_* functions run the outcome UPDATE and the consumed-signal DELETE in one transaction. concurrency_key serialization (advisory lock) helpers live here too; the caller is responsible for holding a single connection (Repo.checkout/1) for the lock's lifetime.