()
| 382 | active_timer.cancel() |
| 383 | |
| 384 | def async_refresh(): |
| 385 | if shutting_down: |
| 386 | return |
| 387 | |
| 388 | store.refresh_registry() |
| 389 | |
| 390 | if registry_ttl_sec: |
| 391 | nonlocal active_timer |
| 392 | active_timer = threading.Timer(registry_ttl_sec, async_refresh) |
| 393 | active_timer.start() |
| 394 | |
| 395 | @asynccontextmanager |
| 396 | async def lifespan(app: FastAPI): |
no test coverage detected