53 lines
1.2 KiB
Ruby
53 lines
1.2 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
module BulkImports
|
|
module Common
|
|
module Pipelines
|
|
class EntityFinisher
|
|
def self.file_extraction_pipeline?
|
|
false
|
|
end
|
|
|
|
def self.abort_on_failure?
|
|
false
|
|
end
|
|
|
|
def initialize(context)
|
|
@context = context
|
|
@entity = @context.entity
|
|
@trackers = @entity.trackers
|
|
end
|
|
|
|
def run
|
|
return if entity.finished? || entity.failed?
|
|
|
|
if all_other_trackers_failed?
|
|
entity.fail_op!
|
|
else
|
|
entity.finish!
|
|
end
|
|
|
|
logger.info(
|
|
pipeline_class: self.class.name,
|
|
message: "Entity #{entity.status_name}"
|
|
)
|
|
|
|
::BulkImports::FinishProjectImportWorker.perform_async(entity.project_id) if entity.project?
|
|
end
|
|
|
|
private
|
|
|
|
attr_reader :context, :entity, :trackers
|
|
|
|
def logger
|
|
@logger ||= Logger.build.with_entity(entity)
|
|
end
|
|
|
|
def all_other_trackers_failed?
|
|
trackers.where.not(relation: self.class.name).all? { |tracker| tracker.failed? } # rubocop: disable CodeReuse/ActiveRecord
|
|
end
|
|
end
|
|
end
|
|
end
|
|
end
|