(self)
| 403 | |
| 404 | # Stop all worker |
| 405 | def stopWorkers(self): |
| 406 | for worker in list(self.workers.values()): |
| 407 | worker.stop() |
| 408 | tasks = self.tasks[:] # Copy |
| 409 | for task in tasks: # Mark all current task as failed |
| 410 | self.failTask(task) |
| 411 | |
| 412 | # Find workers by task |
| 413 | def findWorkers(self, task): |
no test coverage detected