(self, job_id: str)
| 66 | self._batches.append((bp, client, job_id)) |
| 67 | |
| 68 | def deregister(self, job_id: str) -> None: |
| 69 | with self._lock: |
| 70 | self._batches = [(b, c, j) for b, c, j in self._batches if j != job_id] |
| 71 | |
| 72 | def cancel_all(self) -> None: |
| 73 | self.stop_event.set() |
no outgoing calls
no test coverage detected