INNER CODE UNIT · Python

_complete_bridge_registration

Soju06/codex-lb · app/main.py:753

    async def _complete_bridge_registration(svc: RingMembershipService, iid: str) -> None:
        if bridge_endpoint_base_url is None:
            await _activate_bridge_membership(svc, iid)
            startup_module.mark_bridge_registration_complete()
            return
        await _validate_bridge_advertise_endpoint_for_multi_replica(
            svc=svc,
            settings=settings,
            instance_id=iid,
            endpoint_base_url=bridge_endpoint_base_url,
        )
        await svc.register(iid, endpoint_base_url=None)
        await _wait_for_bridge_advertise_endpoint(
            bridge_endpoint_base_url,
            connect_timeout_seconds=effective_settings(
                await get_settings_cache().get(), settings
            ).upstream_connect_timeout_seconds,
        )

View source record →