Dundo777 edited a comment on issue #13529: URL: https://github.com/apache/airflow/issues/13529#issuecomment-756763928
I think I found what might be problem. In scheduler_job.py around line number 1210 "#Check state of finished tasks" it queries task_instances table but with wrong filter parameter. Time is one hour behind. In task_instances table I see the dag run with success state and execution date e.g. 14 o'clock and filter in scheduler_job.py is filtering for 13 o'clock. and 14 o'clock is the correct time, so time that is written in task_instances table is correct. The filter time is wrong. But I didn't yet figure out where that date is setup. Maybe some of you will know that by heart? :) In airflow.cfg default_timezone = Europe/Zagreb and that's consistent with the task_instances execution_date time. Even though, AFAIK Airflow should store everything in utc internally which means that the time saved in database is not correct, right? ---------------------------------------------------------------- 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]
