From 119c94ea17348b30785f44993131bbed13e222ba Mon Sep 17 00:00:00 2001
From: Mike Reeves <luke@geekempire.com>
Date: Tue, 27 Nov 2018 13:42:40 -0500
Subject: [PATCH] Logstash Module - Fix so logstash workers gets picked up

---
 salt/logstash/files/logstash.yml | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/salt/logstash/files/logstash.yml b/salt/logstash/files/logstash.yml
index 592716c96..a783a3f91 100644
--- a/salt/logstash/files/logstash.yml
+++ b/salt/logstash/files/logstash.yml
@@ -219,9 +219,13 @@ path.logs: /var/log/logstash
 #
 # Where to find custom plugins
 # path.plugins: []
-
+{% if grains['role'] == 'so-master' %}
 {% set pipeline_workers = salt['pillar.get']('master:ls_pipeline_workers', '1') %}
 {% set pipeline_batch = salt['pillar.get']('master:ls_pipeline_batch_size', '125') %}
+{% else %}
+{% set pipeline_workers = salt['pillar.get']('node:ls_pipeline_workers', '1') %}
+{% set pipeline_batch = salt['pillar.get']('node:ls_pipeline_batch_size', '125') %}
+{% endif %}
 
 pipeline.workers: {{ pipeline_workers }}
 pipeline.batch.size: {{ pipeline_batch }}