等待子依赖结果
(self)
| 158 | self._waiter.set() |
| 159 | |
| 160 | async def wait(self): |
| 161 | """等待子依赖结果""" |
| 162 | await self._waiter.wait() |
| 163 | if self._state != CacheState.FINISHED: |
| 164 | raise RuntimeError("Invalid cache state") |
| 165 | |
| 166 | if self._exception is not None: |
| 167 | raise self._exception |
| 168 | |
| 169 | return self._result |
| 170 | |
| 171 | |
| 172 | class DependParam(Param): |
no outgoing calls