File "/home/airflow/.local/lib/python3.10/site-packages/airflow/operators/python.py", line 175, in execute
return_value = self.execute_callable()
File "/home/airflow/.local/lib/python3.10/site-packages/airflow/operators/python.py", line 193, in execute_callable
return self.python_callable(*self.op_args, **self.op_kwargs)
File "/opt/airflow/dlme_airflow/tasks/index.py", line 25, in index_collection
return response.json()["message"]
KeyError: 'message'```
This is probably a data error somewhere earlier in the DAG, maybe there are invalid urls in the IR or duplicate ids, etc.