Skip to content

Commit d1ea418

Browse files
committed
Remove move member function in Job (mrq/job.py)
1 parent a3fc2ec commit d1ea418

2 files changed

Lines changed: 0 additions & 11 deletions

File tree

mrq/exceptions.py

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -27,10 +27,6 @@ class AbortInterrupt(_MrqInterrupt):
2727
pass
2828

2929

30-
class MovedInterrupt(_MrqInterrupt):
31-
pass
32-
33-
3430
class RetryInterrupt(_MrqInterrupt):
3531
delay = None
3632
queue = None

mrq/job.py

Lines changed: 0 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -270,13 +270,6 @@ def requeue(self, queue=None, retry_count=0):
270270
"retry_count": retry_count
271271
})
272272

273-
def move(self, queue=None, retry_count=0):
274-
""" Cancel and requeues the current job in an other queue."""
275-
exc = MovedInterrupt()
276-
self._attach_original_exception(exc)
277-
self.requeue(queue, retry_count)
278-
raise exc
279-
280273
def perform(self):
281274
""" Loads and starts the main task for this job, the saves the result. """
282275

0 commit comments

Comments
 (0)