diff --git a/turbo_hipster/task_plugins/gate_real_db_upgrade/task.py b/turbo_hipster/task_plugins/gate_real_db_upgrade/task.py
index a9f9e4b..4855309 100644
--- a/turbo_hipster/task_plugins/gate_real_db_upgrade/task.py
+++ b/turbo_hipster/task_plugins/gate_real_db_upgrade/task.py
@@ -308,11 +308,7 @@
         This can provide a progress bar. """
 
         # Each opportunity we should check if we need to stop
-        if self.stopped():
-            self.work_data['result'] = "Failed: Worker interrupted/stopped"
-            self.job.sendWorkStatus(self.current_step, self.total_steps)
-            raise Exception('Thread stopped')
-        elif self.cancelled:
+        if self.cancelled:
             self.work_data['result'] = "Failed: Job cancelled"
             self.job.sendWorkStatus(self.current_step, self.total_steps)
             self.job.sendWorkFail()