diff --git a/app/celery/scheduled_tasks.py b/app/celery/scheduled_tasks.py
index d6522432a..78865acd3 100644
--- a/app/celery/scheduled_tasks.py
+++ b/app/celery/scheduled_tasks.py
@@ -130,9 +130,9 @@ def check_job_status():
         )
     )
 
-    jobs_not_complete_after_allotted_time = db.session.execute(
-        jobs_not_completed_after_allotted_time
-    ).scalars().all()
+    jobs_not_complete_after_allotted_time = (
+        db.session.execute(jobs_not_completed_after_allotted_time).scalars().all()
+    )
 
     # temporarily mark them as ERROR so that they don't get picked up by future check_job_status tasks
     # if they haven't been re-processed in time.
@@ -141,8 +141,6 @@ def check_job_status():
         job.job_status = JobStatus.ERROR
         dao_update_job(job)
         job_ids.append(str(job.id))
-
-        job_ids.append(str(job.id))
     if job_ids:
         current_app.logger.info("Job(s) {} have not completed.".format(job_ids))
         process_incomplete_jobs.apply_async([job_ids], queue=QueueNames.JOBS)
diff --git a/app/models.py b/app/models.py
index ec6eac335..914fa0142 100644
--- a/app/models.py
+++ b/app/models.py
@@ -1385,6 +1385,7 @@ class Job(db.Model):
         index=True,
         nullable=False,
         default=JobStatus.PENDING,
+        native_enum=False,
     )
     archived = db.Column(db.Boolean, nullable=False, default=False)