From 2e91f2733626a4befc5e55364a4c318d1ad8845d Mon Sep 17 00:00:00 2001
From: weslambert <wlambertts@gmail.com>
Date: Tue, 6 Jul 2021 14:17:49 -0400
Subject: [PATCH] Add conditional for heavynode

---
 .../logstash/pipelines/config/so/9999_output_redis.conf.jinja | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/salt/logstash/pipelines/config/so/9999_output_redis.conf.jinja b/salt/logstash/pipelines/config/so/9999_output_redis.conf.jinja
index 626ed62c3..a70e309e4 100644
--- a/salt/logstash/pipelines/config/so/9999_output_redis.conf.jinja
+++ b/salt/logstash/pipelines/config/so/9999_output_redis.conf.jinja
@@ -1,4 +1,8 @@
+{%- if grains.role in ['so-heavynode'] %}
+{%- set MANAGER = salt['grains.get']('host') %}
+{%- else %}
 {%- set MANAGER = salt['grains.get']('master') %}
+{%- endif %}
 {% set BATCH = salt['pillar.get']('logstash_settings:ls_pipeline_batch_size', 125) %}
 output {
 	redis {