diff --git a/app/models/ci/build_trace_chunk.rb b/app/models/ci/build_trace_chunk.rb index 4884e355c36d56711698491dc23f9e9f06106077..f17d8a07b130d9c15c7e643237db2bb8a54b96b6 100644 --- a/app/models/ci/build_trace_chunk.rb +++ b/app/models/ci/build_trace_chunk.rb @@ -52,7 +52,7 @@ module Ci end # Find stale live traces and return their build ids - def find_stale(finished_before: 1.hour.ago) + def find_stale_in_batches(finished_before: 1.hour.ago) include(EachBatch) .select(:build_id) .group(:build_id) diff --git a/app/workers/all_queues.yml b/app/workers/all_queues.yml index 85d9dcbc3c95c462cdd0db28332d815146fd8cb4..81e971a67d0396a1f8874fc725c38b3aa0eefea9 100644 --- a/app/workers/all_queues.yml +++ b/app/workers/all_queues.yml @@ -17,7 +17,7 @@ - cronjob:stuck_ci_jobs - cronjob:stuck_import_jobs - cronjob:stuck_merge_jobs -- cronjob:rescue_stale_live_trace +- cronjob:ci_rescue_stale_live_trace - cronjob:trending_projects - cronjob:issue_due_scheduler diff --git a/app/workers/ci/rescue_stale_live_trace_worker.rb b/app/workers/ci/rescue_stale_live_trace_worker.rb index 0f196993669742196b6659aac303fd75b42e0161..be0194b63aea0b9e6556f4ec8b7ea7eee108d6d2 100644 --- a/app/workers/ci/rescue_stale_live_trace_worker.rb +++ b/app/workers/ci/rescue_stale_live_trace_worker.rb @@ -9,7 +9,7 @@ module Ci # The targets are jobs with the following conditions # - Jobs had been finished 1 hour ago, but they don't have an archived trace yet # This could happen when their sidekiq-jobs are lost by SIGKILL - Ci::BuildTraceChunk.find_stale(finished_before: 1.hour.ago) do |build_ids| + Ci::BuildTraceChunk.find_stale_in_batches(finished_before: 1.hour.ago) do |build_ids| Ci::Build.where(id: build_ids).find_each do |build| begin build.trace.archive! diff --git a/config/initializers/1_settings.rb b/config/initializers/1_settings.rb index ed6a8a9b3db13bb6794cc09634e5202a59a553f1..165f838e432f9ae7479364181d6790ea1e70d289 100644 --- a/config/initializers/1_settings.rb +++ b/config/initializers/1_settings.rb @@ -289,9 +289,9 @@ Settings.cron_jobs['repository_archive_cache_worker']['job_class'] = 'Repository Settings.cron_jobs['import_export_project_cleanup_worker'] ||= Settingslogic.new({}) Settings.cron_jobs['import_export_project_cleanup_worker']['cron'] ||= '0 * * * *' Settings.cron_jobs['import_export_project_cleanup_worker']['job_class'] = 'ImportExportProjectCleanupWorker' -Settings.cron_jobs['rescue_stale_live_trace_worker'] ||= Settingslogic.new({}) -Settings.cron_jobs['rescue_stale_live_trace_worker']['cron'] ||= '17 * * * *' -Settings.cron_jobs['rescue_stale_live_trace_worker']['job_class'] = 'RescueStaleLiveTraceWorker' +Settings.cron_jobs['ci_rescue_stale_live_trace_worker'] ||= Settingslogic.new({}) +Settings.cron_jobs['ci_rescue_stale_live_trace_worker']['cron'] ||= '17 * * * *' +Settings.cron_jobs['ci_rescue_stale_live_trace_worker']['job_class'] = 'RescueStaleLiveTraceWorker' Settings.cron_jobs['requests_profiles_worker'] ||= Settingslogic.new({}) Settings.cron_jobs['requests_profiles_worker']['cron'] ||= '0 0 * * *' Settings.cron_jobs['requests_profiles_worker']['job_class'] = 'RequestsProfilesWorker'