(self, bp: Any, client: Any, job_id: str)
| 62 | self.stop_event = threading.Event() |
| 63 | |
| 64 | def register(self, bp: Any, client: Any, job_id: str) -> None: |
| 65 | with self._lock: |
| 66 | self._batches.append((bp, client, job_id)) |
| 67 | |
| 68 | def deregister(self, job_id: str) -> None: |
| 69 | with self._lock: |
no outgoing calls
no test coverage detected