(self, methodname: str)
| 76 | return failure.value.subFailure |
| 77 | |
| 78 | def _process_parallel_dfd(self, methodname: str) -> Deferred[list[None]]: |
| 79 | methods = cast( |
| 80 | "Iterable[Callable[..., Coroutine[Any, Any, None] | Deferred[None] | None]]", |
| 81 | self.methods[methodname], |
| 82 | ) |
| 83 | |
| 84 | dfds = [self._get_dfd(m) for m in methods] |
| 85 | d: Deferred[list[tuple[bool, None]]] = DeferredList( |
| 86 | dfds, fireOnOneErrback=True, consumeErrors=True |
| 87 | ) |
| 88 | d2: Deferred[list[None]] = d.addCallback(lambda r: [x[1] for x in r]) |
| 89 | |
| 90 | d2.addErrback(self._eb) |
| 91 | return d2 |
| 92 | |
| 93 | def get_awaitable( |
| 94 | self, |
no test coverage detected