Add raw logging

cinek810 · Oct 23, 2023 · 38b8146 · 38b8146
1 parent 9013918
commit 38b8146
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/source/modules/runners/run.py b/source/modules/runners/run.py
@@ -133,9 +133,12 @@ def run_playitem(self, config: dict, options: dict, inventory: str, lockpath: st
                 self.logger.debug("Running '%s'.", command)
                 try:
                     with subprocess.Popen(command, stdout=subprocess.PIPE, stderr=subprocess.STDOUT,
-                                          env=command_env) as proc:
+                                          env=command_env) as proc, open(f"{self.log_path}.raw", "a",
+                                                  encoding="utf-8") as raw_log:
+
 
                         for msg in proc.stdout:
+                            raw_log.write(msg.decode("utf-8"))
                             dec_msg = msg.split(b"\n")[0].decode("utf-8")
                             returned.append(dec_msg)
                             if options["raw_output"]:
@@ -169,7 +172,7 @@ def run_playitem(self, config: dict, options: dict, inventory: str, lockpath: st
                                                                      self.sequence_id)
                     db_writer.finalize_db_write(sequence_records, True)
                     sys.exit(72)
-            return sequence_records
+                return sequence_records
 
     @staticmethod
     def get_tags_for_task(config: dict, options: dict):