diff --git a/airflow/dags/remove_old_indexes.py b/airflow/dags/remove_old_indexes.py
index 44b8055..df423da 100644
--- a/airflow/dags/remove_old_indexes.py
+++ b/airflow/dags/remove_old_indexes.py
@@ -36,8 +36,9 @@ def remove_old_indexes():
     def remove_indexes():
         context = get_current_context()
         client = get_opensearch_client(context)
-        indexes = client.cat.indices()
-        aliases = client.cat.aliases()
+
+        indexes = client.cat.indices(format="json")
+        aliases = client.cat.aliases(format="json")
 
         print(json.dumps(aliases))
         print(json.dumps(indexes))