Repository: incubator-airflow Updated Branches: refs/heads/master c7e39683d -> d4dfe2654
[AIRFLOW-2059] taskinstance query is awful, un-indexed, and does not scale Closes #3086 from feng-tao/airflow-2059 Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/d4dfe265 Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/d4dfe265 Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/d4dfe265 Branch: refs/heads/master Commit: d4dfe2654e16d1ae2e7464e642a3520de04496e2 Parents: c7e3968 Author: Tao feng <tf...@lyft.com> Authored: Fri Mar 2 09:26:00 2018 +0100 Committer: Fokko Driesprong <fokkodriespr...@godatadriven.com> Committed: Fri Mar 2 09:26:00 2018 +0100 ---------------------------------------------------------------------- airflow/models.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/d4dfe265/airflow/models.py ---------------------------------------------------------------------- diff --git a/airflow/models.py b/airflow/models.py index f2c3f2e..20996e0 100755 --- a/airflow/models.py +++ b/airflow/models.py @@ -780,7 +780,7 @@ class TaskInstance(Base, LoggingMixin): max_tries = Column(Integer) hostname = Column(String(1000)) unixname = Column(String(1000)) - job_id = Column(Integer) + job_id = Column(Integer, index=True) pool = Column(String(50)) queue = Column(String(50)) priority_weight = Column(Integer)