(self)
| 150 | |
| 151 | # Skip current task |
| 152 | def skip(self): |
| 153 | self.manager.log.debug("%s: Force skipping" % self.key) |
| 154 | if self.thread: |
| 155 | self.thread.kill(exception=Debug.Notify("Worker stopped")) |
| 156 | self.start() |
| 157 | |
| 158 | # Force stop the worker |
| 159 | def stop(self): |