You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@airflow.apache.org by GitBox <gi...@apache.org> on 2021/02/06 17:07:53 UTC

[GitHub] [airflow] kaxil commented on a change in pull request #14048: Speed up clear_task_instances by doing a single sql delete for TaskReschedule

kaxil commented on a change in pull request #14048:
URL: https://github.com/apache/airflow/pull/14048#discussion_r571459217



##########
File path: airflow/models/taskinstance.py
##########
@@ -145,7 +145,11 @@ def clear_task_instances(
     :param activate_dag_runs: flag to check for active dag run
     :param dag: DAG object
     """
+    from sqlalchemy import and_, or_

Review comment:
       this can go at the top of the file




----------------------------------------------------------------
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:
users@infra.apache.org