devgonvarun commented on issue #53926: URL: https://github.com/apache/airflow/issues/53926#issuecomment-3179772385
I think I found the exact issue: The [log_id_template](https://github.com/apache/airflow/blob/5a4b4904b00c23cdddf662c33be31796f541056d/providers/opensearch/src/airflow/providers/opensearch/log/os_task_handler.py#L299) in the os_task_handler.py is presently set to the elasticsearch_id value from the log_template table of the metadata db which is always a fixed value of `{dag_id}_{task_id}_{execution_date}_{try_number}` <img width="1355" height="262" alt="Image" src="https://github.com/user-attachments/assets/f31e21b1-4b63-475c-a32c-77b184c1d781"; /> instead it should be something like: `log_id_template = self.log_id_template` which then picks up the default log_id_template with run_id and map_index of the execution_date. @eladkal and @Owen-CH-Leung Please let me know what you think. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
