Fix the migration

ckanext/datapusher_plus/migration/datapusher_plus/versions/01_e9c4a88839c8_upgrade_jobs_table.py

@@ -19,26 +19,27 @@
 
 def upgrade():
     # upgrade jobs table if it not exists
-    if _check_column_exists("jobs", "aps_job_id"):
-        return
-    else:
+    if not _check_column_exists("jobs", "aps_job_id"):
         op.add_column(
             "jobs",
             sa.Column("aps_job_id", sa.UnicodeText),
         )
-
     # upgrade logs table
-    if _check_column_exists("logs", "id"):
-        return
-    else:
+    if not _check_column_exists("logs", "id"):
         op.add_column(
             "logs",
             sa.Column("id", sa.Integer, primary_key=True, autoincrement=True),
         )
 
 
 def downgrade():
-    pass
+    # downgrade jobs table
+    if _check_column_exists("jobs", "aps_job_id"):
+        op.drop_column("jobs", "aps_job_id")
+
+    # downgrade logs table
+    if _check_column_exists("logs", "id"):
+        op.drop_column("logs", "id")
 
 
 def _check_column_exists(table_name, column_name):