[ https://issues.apache.org/jira/browse/AIRFLOW-1493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Alex Guziel resolved AIRFLOW-1493. ---------------------------------- Resolution: Fixed Fix Version/s: 1.9.0 Issue resolved by pull request #2505 [https://github.com/apache/incubator-airflow/pull/2505] > Fix race condition with airflow run > ----------------------------------- > > Key: AIRFLOW-1493 > URL: https://issues.apache.org/jira/browse/AIRFLOW-1493 > Project: Apache Airflow > Issue Type: Bug > Reporter: Alex Guziel > Assignee: Alex Guziel > Fix For: 1.9.0 > > > Currently, airflow run spawns a process `airflow run --local` which spawns > `airflow run --raw`. > Local manages the heartbeat. Raw performs a series of checks, sets the state > to running, runs the task, then sets the state to failed or success. > The problem is the heartbeat check on `airflow run --local` has to monitor > the state in the DB, but because the change of state to running happens > asynchronously, it must first observe the state in the DB to be running > before it has the power of termination. However, there is no guarantee that > it will observe this state. Thus, we should move the pre-execution logic to > airflow run --local -- This message was sent by Atlassian JIRA (v6.4.14#64029)