blob: e3930ee9d418952900dc6c97e7cf914783d5fbb8 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
|
class ExpireJobCacheWorker
include Sidekiq::Worker
include BuildQueue
def perform(pipeline_id, job_id)
job = CommitStatus.joins(:pipeline, :project).find_by(id: job)
return unless job
pipeline = job.pipeline
project = job.project
store.touch(project_pipeline_path(project, pipeline))
store.touch(project_job_path(project, job))
end
private
def project_pipeline_path(project, pipeline)
Gitlab::Routing.url_helpers.namespace_project_pipeline_path(
project.namespace,
project,
pipeline,
format: :json)
end
def project_job_path(project, job)
Gitlab::Routing.url_helpers.namespace_project_build_path(
project.namespace,
project,
job.id,
format: :json)
end
def store
@store ||= Gitlab::EtagCaching::Store.new
end
end
|