diff --git a/logstash-core/lib/logstash/config/source/multi_local.rb b/logstash-core/lib/logstash/config/source/multi_local.rb index 2a523e85031..14697835cba 100644 --- a/logstash-core/lib/logstash/config/source/multi_local.rb +++ b/logstash-core/lib/logstash/config/source/multi_local.rb @@ -30,7 +30,7 @@ def initialize(settings) end def pipeline_configs - pipelines = retrieve_yaml_pipelines + pipelines = deep_replace(retrieve_yaml_pipelines) pipelines_settings = pipelines.map do |pipeline_settings| clone = @original_settings.clone clone.merge_pipeline_settings(pipeline_settings) diff --git a/logstash-core/spec/logstash/config/source/multi_local_spec.rb b/logstash-core/spec/logstash/config/source/multi_local_spec.rb index 2d7747da5ce..a8e9b4a3791 100644 --- a/logstash-core/spec/logstash/config/source/multi_local_spec.rb +++ b/logstash-core/spec/logstash/config/source/multi_local_spec.rb @@ -146,16 +146,17 @@ describe "#pipeline_configs" do - let(:config_string) { - "input { - udp { - port => 5555 # intentional comment contains \"${UDP_DEV_PORT}\" variable, shouldn't break functionalities - host => \"127.0.0.1\" - } - # another intentional comment contains \"${UDP_PROD_HOST}\" variable, shouldn't break functionalities - } - output {}" - } +# let(:config_string) { +# "input { +# udp { +# port => 5555 # intentional comment contains \"${UDP_DEV_PORT}\" variable, shouldn't break functionalities +# host => \"127.0.0.1\" +# } +# # another intentional comment contains \"${UDP_PROD_HOST}\" variable, shouldn't break functionalities +# } +# output {}" +# } + let(:config_string) { "input {} output {}" } let(:retrieved_pipelines) do [ { "pipeline.id" => "main", "config.string" => config_string },