lib/chronicle/etl/cli/connectors.rb in chronicle-etl-0.5.4 vs lib/chronicle/etl/cli/connectors.rb in chronicle-etl-0.5.5
- old
+ new
@@ -11,11 +11,11 @@
namespace :connectors
desc "list", "Lists available connectors"
# Display all available connectors that chronicle-etl has access to
def list
- connector_info = Chronicle::ETL::Registry.connectors.map do |connector_registration|
+ connector_info = Chronicle::ETL::Registry::Connectors.connectors.map do |connector_registration|
{
identifier: connector_registration.identifier,
phase: connector_registration.phase,
description: connector_registration.descriptive_phrase,
provider: connector_registration.provider,
@@ -41,10 +41,10 @@
unless ['extractor', 'transformer', 'loader'].include?(phase)
cli_fail(message: "Phase argument must be one of: [extractor, transformer, loader]")
end
begin
- connector = Chronicle::ETL::Registry.find_by_phase_and_identifier(phase.to_sym, identifier)
+ connector = Chronicle::ETL::Registry::Connectors.find_by_phase_and_identifier(phase.to_sym, identifier)
rescue Chronicle::ETL::ConnectorNotAvailableError, Chronicle::ETL::PluginError => e
cli_fail(message: "Could not find #{phase} #{identifier}", exception: e)
end
puts connector.klass.to_s.bold