设置子依赖异常
(self, exception: BaseException)
| 148 | self._waiter.set() |
| 149 | |
| 150 | def set_exception(self, exception: BaseException) -> None: |
| 151 | """设置子依赖异常""" |
| 152 | |
| 153 | if self._state != CacheState.PENDING: |
| 154 | raise RuntimeError(f"Cache state invalid: {self._state}") |
| 155 | |
| 156 | self._exception = exception |
| 157 | self._state = CacheState.FINISHED |
| 158 | self._waiter.set() |
| 159 | |
| 160 | async def wait(self): |
| 161 | """等待子依赖结果""" |