Add 'error_worker_version' to jobs that fail and are retried, to aid in debuggingdm-sidekiq-versioning

1 files changed, 6 insertions, 0 deletions

diff --git a/lib/gitlab/sidekiq_versioning/job_retry.rb b/lib/gitlab/sidekiq_versioning/job_retry.rb
index 70d3e2e94bf..84fba6f6156 100644
--- a/lib/gitlab/sidekiq_versioning/job_retry.rb
+++ b/lib/gitlab/sidekiq_versioning/job_retry.rb
@@ -15,6 +15,12 @@ module Gitlab
         end
       end
 
+      def attempt_retry(worker, job, queue, exception)
+        job['error_worker_version'] = worker&.class&.version || 'unknown'
+
+        super(worker, job, queue, exception)
+      end
+
       private
 
       def worker_name_error?(e, class_name)