diff options
Diffstat (limited to 'app/workers/expire_job_cache_worker.rb')
| -rw-r--r-- | app/workers/expire_job_cache_worker.rb | 14 |
1 files changed, 6 insertions, 8 deletions
diff --git a/app/workers/expire_job_cache_worker.rb b/app/workers/expire_job_cache_worker.rb index e3930ee9d41..08e281e7350 100644 --- a/app/workers/expire_job_cache_worker.rb +++ b/app/workers/expire_job_cache_worker.rb @@ -2,15 +2,17 @@ class ExpireJobCacheWorker include Sidekiq::Worker include BuildQueue - def perform(pipeline_id, job_id) - job = CommitStatus.joins(:pipeline, :project).find_by(id: job) + def perform(job_id) + job = CommitStatus.joins(:pipeline, :project).find_by(id: job_id) return unless job pipeline = job.pipeline project = job.project - store.touch(project_pipeline_path(project, pipeline)) - store.touch(project_job_path(project, job)) + Gitlab::EtagCaching::Store.new.tap do |store| + store.touch(project_pipeline_path(project, pipeline)) + store.touch(project_job_path(project, job)) + end end private @@ -30,8 +32,4 @@ class ExpireJobCacheWorker job.id, format: :json) end - - def store - @store ||= Gitlab::EtagCaching::Store.new - end end |