Class: Ci::PipelineCleanupRefWorker
- Inherits:
-
Object
- Object
- Ci::PipelineCleanupRefWorker
- Includes:
- ApplicationWorker, PipelineQueue, Projects::RemoveRefs
- Defined in:
- app/workers/ci/pipeline_cleanup_ref_worker.rb
Constant Summary
Constants included from Projects::RemoveRefs
Projects::RemoveRefs::LOCK_RETRY, Projects::RemoveRefs::LOCK_SLEEP, Projects::RemoveRefs::LOCK_TTL
Constants included from Gitlab::ExclusiveLeaseHelpers
Gitlab::ExclusiveLeaseHelpers::FailedToObtainLockError
Constants included from ApplicationWorker
ApplicationWorker::LOGGING_EXTRA_KEY, ApplicationWorker::SAFE_PUSH_BULK_LIMIT
Constants included from Gitlab::Loggable
Constants included from WorkerAttributes
WorkerAttributes::DEFAULT_DATA_CONSISTENCY, WorkerAttributes::DEFAULT_DEFER_DELAY, WorkerAttributes::NAMESPACE_WEIGHTS, WorkerAttributes::VALID_DATA_CONSISTENCIES, WorkerAttributes::VALID_RESOURCE_BOUNDARIES, WorkerAttributes::VALID_URGENCIES
Instance Method Summary collapse
-
#perform(pipeline_id) ⇒ Object
Even though this worker is de-duplicated we need to acquire lock on a project to avoid running many concurrent refs removals.
Methods included from Projects::RemoveRefs
#lock_params, #serialized_remove_refs
Methods included from Gitlab::ExclusiveLeaseHelpers
Methods included from Gitlab::Loggable
Methods included from Gitlab::SidekiqVersioning::Worker
Methods included from WorkerContext
Instance Method Details
#perform(pipeline_id) ⇒ Object
Even though this worker is de-duplicated we need to acquire lock on a project to avoid running many concurrent refs removals
TODO: Once underlying fix is done we can remove ‘in_lock`
Related to:
25 26 27 28 29 30 31 32 33 |
# File 'app/workers/ci/pipeline_cleanup_ref_worker.rb', line 25 def perform(pipeline_id) pipeline = Ci::Pipeline.find_by_id(pipeline_id) return unless pipeline return unless pipeline.persistent_ref.should_delete? serialized_remove_refs(pipeline.project_id) do pipeline.reset.persistent_ref.delete end end |