(self)
| 28 | |
| 29 | class WeTextProcessingManager: |
| 30 | def __init__(self) -> None: |
| 31 | self._lock = threading.Lock() |
| 32 | self._normalize_lock = threading.Lock() |
| 33 | self._thread: threading.Thread | None = None |
| 34 | self._started = False |
| 35 | self._state = "pending" |
| 36 | self._message = "Waiting for WeTextProcessing preload." |
| 37 | self._error: str | None = None |
| 38 | self._available = True |
| 39 | self._normalizers: dict[str, object] | None = None |
| 40 | |
| 41 | def snapshot(self) -> TextNormalizationSnapshot: |
| 42 | with self._lock: |
nothing calls this directly
no outgoing calls
no test coverage detected