class Avrolution::Rake::CheckCompatibilityTask

Public Class Methods

new(**) click to toggle source
Calls superclass method Avrolution::Rake::BaseTask::new
# File lib/avrolution/rake/check_compatibility_task.rb, line 9
def initialize(**)
  super
  @name ||= :check_compatibility
  @task_desc ||= 'Check that all Avro schemas are compatible with latest registered in production'
end

Private Instance Methods

perform() click to toggle source
# File lib/avrolution/rake/check_compatibility_task.rb, line 17
def perform
  check = Avrolution::CompatibilityCheck.new.call
  if check.success?
    puts 'All schemas are compatible!'
  else
    puts "\nIncompatible schemas found: #{check.incompatible_schemas.join(', ')}"
    exit(1)
  end
end