(self)
| 57 | """ |
| 58 | |
| 59 | def __init__(self) -> None: |
| 60 | self._lock = threading.Lock() |
| 61 | self._batches: list[tuple[Any, Any, str]] = [] # (bp, client, job_id) |
| 62 | self.stop_event = threading.Event() |
| 63 | |
| 64 | def register(self, bp: Any, client: Any, job_id: str) -> None: |
| 65 | with self._lock: |
nothing calls this directly
no outgoing calls
no test coverage detected