This commit is contained in:
Dinesh Yeduguru 2024-11-01 10:15:34 -07:00 committed by Dinesh Yeduguru
parent 63f45c1e27
commit ef64863616

View file

@ -35,6 +35,7 @@ class DiskRegistry(Registry):
return [DESERIALIZER.parse(obj_str) for obj_str in objects_data]
# TODO: make it thread safe using CAS
async def register(self, obj: RoutableObjectWithProvider) -> None:
# Get existing objects for this identifier
existing_objects = await self.get(obj.identifier)