Class: MergeRequests::DeleteNonLatestDiffsService
- Inherits:
-
Object
- Object
- MergeRequests::DeleteNonLatestDiffsService
- Defined in:
- app/services/merge_requests/delete_non_latest_diffs_service.rb
Constant Summary collapse
- BATCH_SIZE =
10
Instance Method Summary collapse
- #execute ⇒ Object
-
#initialize(merge_request) ⇒ DeleteNonLatestDiffsService
constructor
A new instance of DeleteNonLatestDiffsService.
Constructor Details
#initialize(merge_request) ⇒ DeleteNonLatestDiffsService
Returns a new instance of DeleteNonLatestDiffsService.
7 8 9 |
# File 'app/services/merge_requests/delete_non_latest_diffs_service.rb', line 7 def initialize(merge_request) @merge_request = merge_request end |
Instance Method Details
#execute ⇒ Object
11 12 13 14 15 16 17 18 |
# File 'app/services/merge_requests/delete_non_latest_diffs_service.rb', line 11 def execute diffs = @merge_request.non_latest_diffs.with_files diffs.each_batch(of: BATCH_SIZE) do |relation, index| ids = relation.pluck_primary_key.map { |id| [id] } DeleteDiffFilesWorker.bulk_perform_in(index * 5.minutes, ids) # rubocop:disable Scalability/BulkPerformWithContext end end |