melle2 commented on issue #11085: URL: https://github.com/apache/airflow/issues/11085#issuecomment-777632469
I now verified the scenario above with released Airflow version 2.0.0. It seems like that everything is fixed and logs are displayed out of the box in Airflow. The only thing what is missing is the output of `end_of_log_mark = end_of_log`. Without that, the "Log view" for a task is still waiting for further log entries. When I manually add `curl -X POST -H 'Content-Type: application/json' -i 'http://elasticsearch_de:9200/airflow/_doc' --data '{"asctime": "2021-02-11 17:24:44,381", "filename": "local_task_job.py", "lineno": 118, "levelname": "INFO", "message": "end_of_log", "dag_id": "stg_cam_asm_load", "task_id": "asm_stage", "execution_date": "2021_02_11T16_24_40_317864", "try_number": "1", "log_id": "--2021-02-11T16:24:40.317864+00:00-1", "offset": 1613060683880414720}'` everything is good. This still needs a fix. ---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: [email protected]
