XD-DENG commented on a change in pull request #12815:
URL: https://github.com/apache/airflow/pull/12815#discussion_r536283195
##########
File path: airflow/jobs/scheduler_job.py
##########
@@ -613,11 +613,6 @@ def process_file(
3. For each DAG, see what tasks should run and create appropriate task
instances in the DB.
4. Record any errors importing the file into ORM
- 5. Kill (in ORM) any task instances belonging to the DAGs that haven't
- issued a heartbeat in a while.
-
- Returns a list of serialized_dag dicts that represent the DAGs found in
- the file
Review comment:
- `DagFileProcessor.process_file()` doesn't take care of killing zombie
anymore.
- The statement of what's returned here is stale
----------------------------------------------------------------
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]
