Minor issue fix in ucc_ta_helper

VatsalJagani · Nov 25, 2024 · 37686d5 · 37686d5
1 parent 1a61164
commit 37686d5
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/utilities/ucc_additional_packaging/ucc_ta_helper.py b/src/utilities/ucc_additional_packaging/ucc_ta_helper.py
@@ -214,8 +214,8 @@ def stream_events(self, inputs: smi.InputDefinition, event_writer: smi.EventWrit
                 # Create event writer for this Input
                 def write_event(data, timestamp=None, index=None, sourcetype=None, source=None):
                     _index = index if index else input_details.get("index")
-                    _sourcetype = index if sourcetype else input_details.get("sourcetype")
-                    _source = index if source else input_details.get("source")
+                    _sourcetype = sourcetype if sourcetype else input_details.get("sourcetype")
+                    _source = source if source else input_details.get("source")
 
                     if type(data) is dict:
                         data = json.dumps(data)