Merge branch 'main' into issue-3749

This commit is contained in:
Matthew Farrellee 2025-10-09 09:56:52 -04:00
commit a8fea981c3
426 changed files with 106834 additions and 36506 deletions

View file

@ -97,11 +97,8 @@ class DiskDistributionRegistry(DistributionRegistry):
async def register(self, obj: RoutableObjectWithProvider) -> bool:
existing_obj = await self.get(obj.type, obj.identifier)
# dont register if the object's providerid already exists
if existing_obj and existing_obj != obj:
raise ValueError(
f"Provider '{obj.provider_id}' is already registered. "
f"Unregister the existing provider first before registering it again."
)
if existing_obj and existing_obj.provider_id == obj.provider_id:
return False
await self.kvstore.set(
KEY_FORMAT.format(type=obj.type, identifier=obj.identifier),