(self, link)
| 214 | return ability_id in [link.ability.ability_id for link in self.chain if link.finish] |
| 215 | |
| 216 | async def apply(self, link): |
| 217 | while self.state != self.states['RUNNING']: |
| 218 | if self.state == self.states['RUN_ONE_LINK']: |
| 219 | self.add_link(link) |
| 220 | self.state = self.states['PAUSED'] |
| 221 | return link.id |
| 222 | else: |
| 223 | await asyncio.sleep(15) |
| 224 | self.add_link(link) |
| 225 | return link.id |
| 226 | |
| 227 | async def close(self, services): |
| 228 | await self._cleanup_operation(services) |