From 9cf9bb180990c8e8c54902eef4896dda55a6dba4 Mon Sep 17 00:00:00 2001 From: "zhijie.huang" Date: Sat, 31 Mar 2018 23:05:41 +0800 Subject: [PATCH] a --- mrq/job.py | 5 +++++ 1 file changed, 5 insertions(+) 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. """