summary refs log tree commit diff
diff options
context:
space:
mode:
authorDavid Robertson <davidr@element.io>2021-11-24 12:35:19 +0000
committerDavid Robertson <davidr@element.io>2021-11-24 12:35:19 +0000
commit6c7aecd67fc45dae0688ff12b0b6864b0358f494 (patch)
tree894f7b27d8d763ebc95c18ea7a0345781fd841fc
parentSlavedEventStore doesn't need StreamWorkerStore (diff)
downloadsynapse-github/dmr/typing/storage/cache.tar.xz
Use _clock again and note the typing problem github/dmr/typing/storage/cache dmr/typing/storage/cache
-rw-r--r--synapse/visibility.py4
1 files changed, 3 insertions, 1 deletions
diff --git a/synapse/visibility.py b/synapse/visibility.py
index 17532059e9..cca1b275b2 100644
--- a/synapse/visibility.py
+++ b/synapse/visibility.py
@@ -146,7 +146,9 @@ async def filter_events_for_client(
                 max_lifetime = retention_policy.get("max_lifetime")
 
                 if max_lifetime is not None:
-                    oldest_allowed_ts = storage.main.clock.time_msec() - max_lifetime
+                    # TODO: reveal_type(storage.main) yields Any. Can we find a way of
+                    # telling mypy that storage.main is a generic `DataStoreT`?
+                    oldest_allowed_ts = storage.main._clock.time_msec() - max_lifetime
 
                     if event.origin_server_ts < oldest_allowed_ts:
                         return None