diff --git a/mrq/job.py b/mrq/job.py
index e4e97d6e..81e5e553 100644
--- a/mrq/job.py
+++ b/mrq/job.py
@@ -250,6 +250,11 @@ def abort(self):
         exc = AbortInterrupt()
         self._attach_original_exception(exc)
         raise exc
+        
+    def interrupt_job(self):
+        """ interrupt the current job mid-excution. """
+        exc = JobInterrupt()
+        raise exc
 
     def cancel(self):
         """ Markes the current job as cancelled. Doesn't interrupt it. """