Contents

# frozen_string_literal: true

require 'avrolution/rake/base_task'

module Avrolution
  module Rake
    class RegisterSchemasTask < BaseTask

      def initialize(*)
        super
        @name ||= :register_schemas
        @task_desc ||= 'Register the specified Avro JSON schemas'
      end

      private

      def perform
        raise 'schemas must be specified' if ENV['schemas'].blank?

        schemas = ENV['schemas'].split(',')

        Avrolution::RegisterSchemas.call(schemas)
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
avrolution-0.7.0	lib/avrolution/rake/register_schemas_task.rb