Class: Gitlab::Ci::Pipeline::Chain::CancelPendingPipelines
- Includes:
- Helpers
- Defined in:
- lib/gitlab/ci/pipeline/chain/cancel_pending_pipelines.rb
Constant Summary collapse
- BATCH_SIZE =
25
Instance Attribute Summary
Attributes inherited from Base
Instance Method Summary collapse
-
#break? ⇒ Boolean
rubocop: enable CodeReuse/ActiveRecord.
-
#perform! ⇒ Object
rubocop: disable CodeReuse/ActiveRecord.
Methods included from Helpers
Methods inherited from Base
Constructor Details
This class inherits a constructor from Gitlab::Ci::Pipeline::Chain::Base
Instance Method Details
#break? ⇒ Boolean
rubocop: enable CodeReuse/ActiveRecord
24 25 26 |
# File 'lib/gitlab/ci/pipeline/chain/cancel_pending_pipelines.rb', line 24 def break? false end |
#perform! ⇒ Object
rubocop: disable CodeReuse/ActiveRecord
13 14 15 16 17 18 19 20 21 |
# File 'lib/gitlab/ci/pipeline/chain/cancel_pending_pipelines.rb', line 13 def perform! return unless project.auto_cancel_pending_pipelines? Gitlab::OptimisticLocking.retry_lock(auto_cancelable_pipelines, name: 'cancel_pending_pipelines') do |cancelables| cancelables.select(:id).each_batch(of: BATCH_SIZE) do |cancelables_batch| auto_cancel_interruptible_pipelines(cancelables_batch.ids) end end end |