Nat 189 ansible return json

lso/playbook.py

 """Module that gathers common API responses and data models."""
 import enum
+import json
 import logging
 import threading
 import uuid
@@ -66,14 +67,31 @@ def _run_playbook_proc(job_id: str, playbook_path: str, extra_vars: dict, invent
     :param str callback: Callback URL to PUT to when execution is completed.
     :param [str] inventory: Ansible inventory to run the playbook against.
     """
-    ansible_playbook_run = ansible_runner.run(playbook=playbook_path, inventory=inventory, extravars=extra_vars)
+    ansible_playbook_run = ansible_runner.run(
+        playbook=playbook_path,
+        inventory=inventory,
+        extravars=extra_vars,
+        json_mode=True,
+    )
+
+    # Process playbook JSON stdout
+    json_output = ansible_playbook_run.stdout
+    json_content = json_output.read()
+
+    parsed_output = []
+    for line in json_content.strip().splitlines():
+        try:
+            task_output = json.loads(line)
+            parsed_output.append(task_output)
+        except json.JSONDecodeError:
+            parsed_output.append({"invalid_json": line})
 
     payload = [
         {
             "pp_run_results": {
                 "status": ansible_playbook_run.status,
                 "job_id": job_id,
-                "output": str(ansible_playbook_run.stdout.read()),
+                "output": json.dumps(parsed_output, indent=4),
                 "return_code": int(ansible_playbook_run.rc),
             },
             "confirm": "ACCEPTED",