support substitutions in pipelines.yml file

elastic · Aug 26, 2019 · 94aa7cf · 94aa7cf
1 parent 2e70df0
commit 94aa7cf
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/logstash-core/lib/logstash/config/source/multi_local.rb b/logstash-core/lib/logstash/config/source/multi_local.rb
@@ -4,6 +4,7 @@
 
 module LogStash module Config module Source
   class MultiLocal < Local
+    include LogStash::Util::SubstitutionVariables
     include LogStash::Util::Loggable
 
     def initialize(settings)
@@ -13,7 +14,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)