INNER CODE UNIT · Python
delay
Soju06/codex-lb · app/main.py:793
delay = min(5.0 * (2 ** min(attempt - 1, 5)), 60.0)
logger.warning("Ring registration attempt %d failed, retrying in %.0fs", attempt, delay, exc_info=True)
await asyncio.sleep(delay)
await refresh_cap_partition(svc.list_active, iid)
await _heartbeat_only(svc, iid)
async def _activate_bridge_membership(svc: RingMembershipService, iid: str) -> None:
if bridge_endpoint_base_url is None:
await svc.register(iid, endpoint_base_url=None)
return
await svc.register(iid, endpoint_base_url=bridge_endpoint_base_url)
ring_service: RingMembershipService | None = None
instance_id: str | None = None
heartbeat_task: asyncio.Task[None] | None = None
ring_service = RingMembershipService(SessionLocal)
instance_id = settings.http_responses_session_bridge_instance_id
heartbeat_task = asyncio.create_task(_register_and_heartbeat(ring_service, instance_id))