From 708cef0ab089879c78dc29b3b9a9ea6ad2917aaf Mon Sep 17 00:00:00 2001 From: Ryan Barrett Date: Thu, 9 Jan 2025 18:32:01 -0800 Subject: [PATCH] atproto_firehose.subscribe: dark read memcache to compare against DIDs in memory for #1341 --- atproto_firehose.py | 3 +++ 1 file changed, 3 insertions(+) diff --git a/atproto_firehose.py b/atproto_firehose.py index 51a6e0c7..a05a912c 100644 --- a/atproto_firehose.py +++ b/atproto_firehose.py @@ -171,6 +171,9 @@ def subscribe(): if not repo: logger.warning(f'Payload missing repo! {payload}') continue + # TODO: remove + elif repo in atproto_dids and not ATProto.get_by_id(repo, use_datastore=False): + report_error('ATProto user missing from memcache', user=repo) seq = payload.get('seq') if not seq: