(self)
| 157 | |
| 158 | # Force stop the worker |
| 159 | def stop(self): |
| 160 | self.manager.log.debug("%s: Force stopping" % self.key) |
| 161 | self.running = False |
| 162 | if self.thread: |
| 163 | self.thread.kill(exception=Debug.Notify("Worker stopped")) |
| 164 | del self.thread |
| 165 | self.manager.removeWorker(self) |
no test coverage detected