Repository: incubator-airflow Updated Branches: refs/heads/master 4cf904cf5 -> e1772c008
[AIRFLOW-1495] Add TaskInstance index on job_id Column job_id is unindexed in TaskInstance, it was used as default sort column in TaskInstanceView. This commit adds the required migration to add the index on task_instance.job_id on future db upgrades. Closes #2520 from edgarRd/erod-ti-jobid-index Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/e1772c00 Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/e1772c00 Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/e1772c00 Branch: refs/heads/master Commit: e1772c008d607a2545ddaa05508b1a74473be0ec Parents: 4cf904c Author: Edgar Rodriguez <edgar.rodrig...@airbnb.com> Authored: Tue Aug 15 14:57:26 2017 -0700 Committer: Dan Davydov <dan.davy...@airbnb.com> Committed: Tue Aug 15 14:57:28 2017 -0700 ---------------------------------------------------------------------- .../7171349d4c73_add_ti_job_id_index.py | 38 ++++++++++++++++++++ 1 file changed, 38 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/e1772c00/airflow/migrations/versions/7171349d4c73_add_ti_job_id_index.py ---------------------------------------------------------------------- diff --git a/airflow/migrations/versions/7171349d4c73_add_ti_job_id_index.py b/airflow/migrations/versions/7171349d4c73_add_ti_job_id_index.py new file mode 100644 index 0000000..b7e2be6 --- /dev/null +++ b/airflow/migrations/versions/7171349d4c73_add_ti_job_id_index.py @@ -0,0 +1,38 @@ +# -*- coding: utf-8 -*- +# +# Licensed under the Apache License, Version 2.0 (the "License"); +# you may not use this file except in compliance with the License. +# You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, software +# distributed under the License is distributed on an "AS IS" BASIS, +# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +# See the License for the specific language governing permissions and +# limitations under the License. + +"""add ti job_id index + +Revision ID: 7171349d4c73 +Revises: cc1e65623dc7 +Create Date: 2017-08-14 18:08:50.196042 + +""" + +# revision identifiers, used by Alembic. +revision = '7171349d4c73' +down_revision = 'cc1e65623dc7' +branch_labels = None +depends_on = None + +from alembic import op +import sqlalchemy as sa + + +def upgrade(): + op.create_index('ti_job_id', 'task_instance', ['job_id'], unique=False) + + +def downgrade(): + op.drop_index('ti_job_id', table_name='task_instance')
