airflow-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davy...@apache.org
Subject incubator-airflow git commit: [AIRFLOW-1495] Add TaskInstance index on job_id
Date Tue, 15 Aug 2017 21:57:44 GMT
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.rodriguez@airbnb.com>
Authored: Tue Aug 15 14:57:26 2017 -0700
Committer: Dan Davydov <dan.davydov@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')


Mime
View raw message