(self, methodname: str)
| 101 | return ensure_awaitable(result, _warn=global_object_name(method)) |
| 102 | |
| 103 | async def _process_parallel_asyncio(self, methodname: str) -> list[None]: |
| 104 | methods = cast( |
| 105 | "Iterable[Callable[..., Coroutine[Any, Any, None] | Deferred[None] | None]]", |
| 106 | self.methods[methodname], |
| 107 | ) |
| 108 | if not methods: |
| 109 | return [] |
| 110 | |
| 111 | awaitables = [self.get_awaitable(m) for m in methods] |
| 112 | await asyncio.gather(*awaitables) |
| 113 | return [None for _ in methods] |
| 114 | |
| 115 | async def _process_parallel(self, methodname: str) -> list[None]: |
| 116 | if is_asyncio_available(): |
no test coverage detected