diff --git a/migrations/versions/0071_add_job_error_state.py b/migrations/versions/0071_add_job_error_state.py
index aafeee36a..4b6eaf5b4 100644
--- a/migrations/versions/0071_add_job_error_state.py
+++ b/migrations/versions/0071_add_job_error_state.py
@@ -19,4 +19,5 @@ def upgrade():
 
 
 def downgrade():
+    op.execute("UPDATE jobs SET job_status = 'finished' WHERE job_status = 'error'")
     op.execute("DELETE FROM JOB_STATUS WHERE name = 'error'")