initial stage

2024-08-06 11:37:23 +02:00 · 2024-08-06 11:37:23 +02:00 · e072311240
parent 2f8c04a6a2
commit e072311240
1 changed files with 3 additions and 2 deletions
--- 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))