(self, task, peer)
| 170 | return False |
| 171 | |
| 172 | def taskAddPeer(self, task, peer): |
| 173 | if task["peers"] is None: |
| 174 | task["peers"] = [] |
| 175 | if peer in task["failed"]: |
| 176 | return False |
| 177 | |
| 178 | if peer not in task["peers"]: |
| 179 | task["peers"].append(peer) |
| 180 | return True |
| 181 | |
| 182 | # Start workers to process tasks |
| 183 | def startWorkers(self, peers=None, force_num=0, reason="Unknown"): |
no outgoing calls
no test coverage detected