diff --git a/enterprise/app/jobs/captain/conversation/response_builder_job.rb b/enterprise/app/jobs/captain/conversation/response_builder_job.rb index 297e78181..698ec56e7 100644 --- a/enterprise/app/jobs/captain/conversation/response_builder_job.rb +++ b/enterprise/app/jobs/captain/conversation/response_builder_job.rb @@ -13,9 +13,7 @@ class Captain::Conversation::ResponseBuilderJob < ApplicationJob if captain_v2_enabled? generate_response_with_v2 else - ActiveRecord::Base.transaction do - generate_and_process_response - end + generate_and_process_response end rescue StandardError => e raise e if e.is_a?(ActiveStorage::FileNotFoundError) || e.is_a?(Faraday::BadRequestError) @@ -44,11 +42,15 @@ class Captain::Conversation::ResponseBuilderJob < ApplicationJob end def process_response - return process_action('handoff') if handoff_requested? - - create_messages - Rails.logger.info("[CAPTAIN][ResponseBuilderJob] Incrementing response usage for #{account.id}") - account.increment_response_usage + ActiveRecord::Base.transaction do + if handoff_requested? + process_action('handoff') + else + create_messages + Rails.logger.info("[CAPTAIN][ResponseBuilderJob] Incrementing response usage for #{account.id}") + account.increment_response_usage + end + end end def collect_previous_messages