()
| 598 | return await existing_task |
| 599 | |
| 600 | async def runner() -> bool: |
| 601 | try: |
| 602 | return await self._refresh_at_inner(token_id) |
| 603 | finally: |
| 604 | current = self._refresh_futures.get(token_id) |
| 605 | if current is task: |
| 606 | self._refresh_futures.pop(token_id, None) |
| 607 | |
| 608 | task = asyncio.create_task(runner()) |
| 609 | self._refresh_futures[token_id] = task |
nothing calls this directly
no test coverage detected