From 5fd2558a3aa9b8f2e51f1d74897d85c15d81c50b Mon Sep 17 00:00:00 2001 From: Giambattista Bloisi Date: Wed, 27 Mar 2024 22:58:50 +0100 Subject: [PATCH] initial stage --- airflow/dags/import_EOSC_graph.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/airflow/dags/import_EOSC_graph.py b/airflow/dags/import_EOSC_graph.py index 9fe9ad7..8e10adb 100644 --- a/airflow/dags/import_EOSC_graph.py +++ b/airflow/dags/import_EOSC_graph.py @@ -212,10 +212,10 @@ for config_name, config in configs.items(): for entity in kwargs["params"]["ENTITIES"]: indexname = f'{entity}_{kwargs["params"]["SUFFIX"]}' client.indices.update_aliases( - actions=[ + body={"actions": [ {"remove": {"index": f"{entity}_*", "alias": entity}}, {"add": {"index": indexname, "alias": entity}}, - ] + ]} ) # update "allresources" alias actions = [] @@ -225,7 +225,7 @@ for config_name, config in configs.items(): actions.append({"add": {"index": "allresources", "alias": entity}}) if len(actions) > 0: client.indices.update_aliases( - actions=actions + body={"actions": actions} ) parallel_batches = PythonOperator(task_id="compute_parallel_batches", python_callable=compute_batches)