Move topics job into AnswerAnalysis module

This is run as part of our answer analysis so it makes sense to
move it into the AnswerAnalysis module.

Author: davidgisbey

app/jobs/answer_analysis/answer_topics_job.rb

@@ -0,0 +1,25 @@
+module AnswerAnalysis
+  class AnswerTopicsJob < ApplicationJob
+    MAX_RETRIES = 5
+    retry_on Anthropic::Errors::APIError, wait: 1.minute, attempts: MAX_RETRIES
+
+    def perform(answer_id)
+      answer = Answer.includes(:topics, question: :conversation).find_by(id: answer_id)
+
+      return logger.warn("No answer found for #{answer_id}") unless answer
+      return logger.warn("Answer #{answer_id} has already been tagged with topics") if answer.topics.present?
+      unless answer.eligible_for_topic_analysis?
+        return logger.info("Answer #{answer_id} is not eligible for topic analysis")
+      end
+
+      result = TopicTagger.call(answer.rephrased_question || answer.question.message)
+      topics = answer.build_topics(
+        primary_topic: result.primary_topic,
+        secondary_topic: result.secondary_topic,
+        llm_response: result.llm_response,
+        metrics: result.metrics,
+      )
+      topics.save!
+    end
+  end
+end

app/jobs/answer_topics_job.rb

@@ -17,7 +17,7 @@ def perform(question_id)
     if answer.persisted?
       # TODO: Once we've added a few metrics we should move these to a single job that
       # kicks off all analysis jobs.
-      AnswerTopicsJob.perform_later(answer.id)
+      AnswerAnalysis::AnswerTopicsJob.perform_later(answer.id)
       AnswerAnalysis::AnswerRelevancyJob.perform_later(answer.id)
     end
   end

app/jobs/compose_answer_job.rb

@@ -0,0 +1,7 @@
+class AutoEvaluationMetricRun < ApplicationRecord
+  include LlmCallsRecordable
+
+  belongs_to :metric_aggregate,
+             class_name: "AutoEvaluationMetricAggregate",
+             foreign_key: :auto_evaluation_metric_aggregate_id
+end

app/models/auto_evaluation_metric_run.rb

@@ -1,4 +1,4 @@
-RSpec.describe AnswerTopicsJob do
+RSpec.describe AnswerAnalysis::AnswerTopicsJob do
   include ActiveJob::TestHelper
   let(:answer) { create(:answer) }
   let(:question) { answer.question }

spec/jobs/answer_topics_job_spec.rb …nswer_analysis/answer_topics_job_spec.rbspec/jobs/answer_topics_job_spec.rb renamed to spec/jobs/answer_analysis/answer_topics_job_spec.rb spec/jobs/answer_topics_job_spec.rb renamed to spec/jobs/answer_analysis/answer_topics_job_spec.rb

@@ -5,7 +5,7 @@
 
   before do
     allow(AnswerComposition::Composer).to receive(:call).and_return(returned_answer)
-    allow(AnswerTopicsJob).to receive(:perform_later)
+    allow(AnswerAnalysis::AnswerTopicsJob).to receive(:perform_later)
     allow(AnswerAnalysis::AnswerRelevancyJob).to receive(:perform_later)
   end
 
@@ -18,9 +18,9 @@
         .and change(AnswerSource, :count).by(2)
     end
 
-    it "calls the AnswerTopicsJob with the answer_id" do
+    it "calls the AnswerAnalysis::AnswerTopicsJob with the answer_id" do
       described_class.new.perform(question.id)
-      expect(AnswerTopicsJob).to have_received(:perform_later).with(returned_answer.id)
+      expect(AnswerAnalysis::AnswerTopicsJob).to have_received(:perform_later).with(returned_answer.id)
     end
 
     it "calls the AnswerAnalysis::AnswerRelevancyJob with the answer_id" do

spec/jobs/compose_answer_job_spec.rb

@@ -73,7 +73,7 @@ def when_i_create_a_conversation
         status: :answered,
       )
     end
-    allow(AnswerTopicsJob).to receive(:perform_later)
+    allow(AnswerAnalysis::AnswerTopicsJob).to receive(:perform_later)
     allow(AnswerAnalysis::AnswerRelevancyJob).to receive(:perform_later)
 
     post api_v1_create_conversation_path,