YaAnuar

I solved this issue by adding new message into elasticsearch: message: "end_of_log" curl -X POST "http://elasticsearch-logs:9200/airflow-logs/_doc/" -H "Content-Type: application/json" -d '{ "log_id": "for_test_start_parse_2024_08_04T06_15_00_000000_1", "message": "end_of_log", "offset": 1 }'