pub async fn mark_inflight( pool: &PgPool, id: i64, now: i64, ) -> Result<(), Error>
mark a message as in-flight