blob: c77e53b9aec98f6146bc4ef15a2eb3591821b27e (
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
|
# frozen_string_literal: true
module BulkImports
module Projects
module Pipelines
class ReleasesPipeline
include NdjsonPipeline
relation_name 'releases'
extractor ::BulkImports::Common::Extractors::NdjsonExtractor, relation: relation
def after_run(_context)
super
portable.releases.find_each do |release|
create_release_evidence(release)
end
end
private
def create_release_evidence(release)
return if release.historical_release? || release.upcoming_release?
::Releases::CreateEvidenceWorker.perform_async(release.id)
end
end
end
end
end
|