Migration added

Author: tino097

ckanext/datapusher_plus/migration/datapusher_plus/versions/03_23d45fa26447_add_job_key.py

@@ -17,8 +17,16 @@
 
 
 def upgrade():
-    op.add_column('jobs', sa.Column('job_key', sa.UnicodeText(), nullable=True))
+    if not _check_column_exists('jobs', 'job_key'):
+       op.add_column('jobs', sa.Column('job_key', sa.UnicodeText(), nullable=True))
 
 
 def downgrade():
     op.drop_column('jobs', 'job_key')
+
+
+def _check_column_exists(table_name, column_name):
+    bind = op.get_bind()
+    insp = sa.engine.reflection.Inspector.from_engine(bind)
+    columns = insp.get_columns(table_name)
+    return column_name in [column["name"] for column in columns]