diff options
Diffstat (limited to 'app/workers/ci/archive_trace_worker.rb')
| -rw-r--r-- | app/workers/ci/archive_trace_worker.rb | 8 |
1 files changed, 2 insertions, 6 deletions
diff --git a/app/workers/ci/archive_trace_worker.rb b/app/workers/ci/archive_trace_worker.rb index 47d77c15b4a..edbaf0536a2 100644 --- a/app/workers/ci/archive_trace_worker.rb +++ b/app/workers/ci/archive_trace_worker.rb @@ -4,17 +4,13 @@ module Ci class ArchiveTraceWorker # rubocop:disable Scalability/IdempotentWorker include ApplicationWorker - data_consistency :sticky, feature_flag: :sticky_ci_archive_trace_worker + data_consistency :sticky sidekiq_options retry: 3 include PipelineBackgroundQueue def perform(job_id) - archivable_jobs = Ci::Build.without_archived_trace - - if Feature.enabled?(:sticky_ci_archive_trace_worker) - archivable_jobs = archivable_jobs.eager_load_for_archiving_trace - end + archivable_jobs = Ci::Build.without_archived_trace.eager_load_for_archiving_trace archivable_jobs.find_by_id(job_id).try do |job| Ci::ArchiveTraceService.new.execute(job, worker_name: self.class.name) |