Skip to content
Snippets Groups Projects
Commit 92743088 authored by Daniel Bimschas's avatar Daniel Bimschas
Browse files

HOLI-10718: handle object not found on deletion gracefully

parent f0f8188a
No related branches found
No related tags found
No related merge requests found
...@@ -4,6 +4,7 @@ from typing import Union ...@@ -4,6 +4,7 @@ from typing import Union
from dataclasses import asdict from dataclasses import asdict
from cloudevents.http.event import CloudEvent from cloudevents.http.event import CloudEvent
from typesense.exceptions import ObjectNotFound
from events import UserNameUpdatedEvent, get_event_type, get_event_version, UserDeletedEvent, SpaceCreatedEvent, \ from events import UserNameUpdatedEvent, get_event_type, get_event_version, UserDeletedEvent, SpaceCreatedEvent, \
SpaceUpdatedEvent, SpaceDeletedEvent SpaceUpdatedEvent, SpaceDeletedEvent
...@@ -20,7 +21,10 @@ def process_user_name_updated_event(client: TypesenseClient, event: UserNameUpda ...@@ -20,7 +21,10 @@ def process_user_name_updated_event(client: TypesenseClient, event: UserNameUpda
def process_user_deleted_event(client: TypesenseClient, event: UserDeletedEvent): def process_user_deleted_event(client: TypesenseClient, event: UserDeletedEvent):
logger.debug(f'Processing {event}') logger.debug(f'Processing {event}')
client.delete(f"profile_{event.user.id}") try:
client.delete(f"profile_{event.user.id}")
except ObjectNotFound:
pass
logger.info(f'Deleted user {event.user.id} from Typesense') logger.info(f'Deleted user {event.user.id} from Typesense')
def process_space_upserting_event(client: TypesenseClient, event: Union[SpaceCreatedEvent, SpaceUpdatedEvent]): def process_space_upserting_event(client: TypesenseClient, event: Union[SpaceCreatedEvent, SpaceUpdatedEvent]):
...@@ -30,7 +34,10 @@ def process_space_upserting_event(client: TypesenseClient, event: Union[SpaceCre ...@@ -30,7 +34,10 @@ def process_space_upserting_event(client: TypesenseClient, event: Union[SpaceCre
def process_space_deleted_event(client: TypesenseClient, event: SpaceDeletedEvent): def process_space_deleted_event(client: TypesenseClient, event: SpaceDeletedEvent):
logger.debug(f'Processing {event}') logger.debug(f'Processing {event}')
client.delete(f"space_{event.space.id}") try:
client.delete(f"space_{event.space.id}")
except ObjectNotFound:
pass
logger.info(f'Deleted space {event.space.id} in Typesense') logger.info(f'Deleted space {event.space.id} in Typesense')
def process_event(client: TypesenseClient, event: CloudEvent): def process_event(client: TypesenseClient, event: CloudEvent):
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment