From bcde15e6f8cee71a5aabd167516182aecad34dce Mon Sep 17 00:00:00 2001 From: Jeong Arm Date: Thu, 3 Nov 2022 11:13:57 +0900 Subject: [PATCH] Fix forwarding delete is ignored by cache --- relay/processors.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/relay/processors.py b/relay/processors.py index 2f8b351..1191f6a 100644 --- a/relay/processors.py +++ b/relay/processors.py @@ -39,8 +39,9 @@ async def handle_relay(actor, data, request): async def handle_forward(actor, data, request): cache = app['cache'].objects object_id = misc.distill_object_id(data) + object_type = data['type'] - if object_id in cache: + if object_id in cache and object_type != 'Delete': logging.verbose(f'already forwarded {object_id}') return