()
| 1924 | ) |
| 1925 | |
| 1926 | def _load_modules(): |
| 1927 | try: |
| 1928 | self.clear_funcs = ClearFuncs( |
| 1929 | self.opts, |
| 1930 | self.key, |
| 1931 | ) |
| 1932 | self.clear_funcs.connect() |
| 1933 | self.aes_funcs = AESFuncs(self.opts) |
| 1934 | except Exception: # pylint: disable=broad-except |
| 1935 | log.exception( |
| 1936 | "%s failed to load modules, worker will be non-functional", |
| 1937 | self.name, |
| 1938 | ) |
| 1939 | finally: |
| 1940 | self._modules_loaded.set() |
| 1941 | self.io_loop.call_soon_threadsafe(self._async_modules_ready.set) |
| 1942 | |
| 1943 | loader_thread = threading.Thread( |
| 1944 | target=_load_modules, name=f"{self.name}-loader", daemon=True |
nothing calls this directly
no test coverage detected