diff options
| author | David Robertson <davidr@element.io> | 2021-11-24 12:35:19 +0000 |
|---|---|---|
| committer | David Robertson <davidr@element.io> | 2021-11-24 12:35:19 +0000 |
| commit | 6c7aecd67fc45dae0688ff12b0b6864b0358f494 (patch) | |
| tree | 894f7b27d8d763ebc95c18ea7a0345781fd841fc | |
| parent | SlavedEventStore doesn't need StreamWorkerStore (diff) | |
| download | synapse-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.py | 4 |
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 |