|
31 | 31 |
|
32 | 32 | from ....__version__ import __version__
|
33 | 33 | from ....utils.async_cache import AsyncSimpleLRUCache
|
34 |
| -from ....utils.async_tools import Lock, async_tasking_event, create_sub_task, threaded |
| 34 | +from ....utils.async_tools import Lock, async_tasking_event, create_sub_task |
35 | 35 | from ....utils.dataclasses import as_json, from_json
|
36 | 36 | from ....utils.glob_path import Pattern, iter_files
|
37 | 37 | from ....utils.logging import LoggingDescriptor
|
@@ -602,13 +602,16 @@ async def variables_changed(sender, variables: List[LibraryDoc]) -> None: # NOS
|
602 | 602 | async def imports_changed(sender, uri: DocumentUri) -> None: # NOSONAR
|
603 | 603 | ...
|
604 | 604 |
|
605 |
| - @threaded() |
606 | 605 | async def _do_imports_changed(self, sender: Any, uri: DocumentUri) -> None: # NOSONAR
|
607 |
| - await self.imports_changed(self, uri) |
| 606 | + create_sub_task(self.imports_changed(self, uri), loop=self.parent_protocol.diagnostics.diagnostics_loop) |
608 | 607 |
|
609 | 608 | @language_id("robotframework")
|
610 |
| - @threaded() |
611 | 609 | async def resource_document_changed(self, sender: Any, document: TextDocument) -> None:
|
| 610 | + create_sub_task( |
| 611 | + self.__resource_document_changed(document), loop=self.parent_protocol.diagnostics.diagnostics_loop |
| 612 | + ) |
| 613 | + |
| 614 | + async def __resource_document_changed(self, document: TextDocument) -> None: |
612 | 615 | resource_changed: List[LibraryDoc] = []
|
613 | 616 |
|
614 | 617 | async with self._resources_lock:
|
|
0 commit comments