async fn record_non_retryable_failure( conn: &mut PgConnection, email_id: Uuid, attempt: i32, error_code: &'static str, message: String, ) -> Result<()>