summary refs log tree commit diff
path: root/synapse/handlers/pagination.py
diff options
context:
space:
mode:
authorAndrew Morgan <andrew@amorgan.xyz>2020-03-23 11:37:40 +0000
committerAndrew Morgan <andrew@amorgan.xyz>2020-03-23 11:37:40 +0000
commit96b48d5bccd5a9873272351420cbe91fea13d12a (patch)
tree9461a4a9617bb746718660c8964ad5acb6bdd4fc /synapse/handlers/pagination.py
parentFix syntax error in run_upgrade for schema 57 (#6728) (diff)
parentAdd more logging around message retention policies support (#6717) (diff)
downloadsynapse-96b48d5bccd5a9873272351420cbe91fea13d12a.tar.xz
Add more logging around message retention policies support (#6717)
* commit 'a17f64361':
  Add more logging around message retention policies support (#6717)
  Fix up changelog
  bump version to v1.9.0.dev2
Diffstat (limited to 'synapse/handlers/pagination.py')
-rw-r--r--synapse/handlers/pagination.py13
1 files changed, 13 insertions, 0 deletions
diff --git a/synapse/handlers/pagination.py b/synapse/handlers/pagination.py

index 3ee6a091c5..71d76202c9 100644 --- a/synapse/handlers/pagination.py +++ b/synapse/handlers/pagination.py
@@ -88,6 +88,8 @@ class PaginationHandler(object): if hs.config.retention_enabled: # Run the purge jobs described in the configuration file. for job in hs.config.retention_purge_jobs: + logger.info("Setting up purge job with config: %s", job) + self.clock.looping_call( run_as_background_process, job["interval"], @@ -130,11 +132,22 @@ class PaginationHandler(object): else: include_null = False + logger.info( + "[purge] Running purge job for %d < max_lifetime <= %d (include NULLs = %s)", + min_ms, + max_ms, + include_null, + ) + rooms = yield self.store.get_rooms_for_retention_period_in_range( min_ms, max_ms, include_null ) + logger.debug("[purge] Rooms to purge: %s", rooms) + for room_id, retention_policy in iteritems(rooms): + logger.info("[purge] Attempting to purge messages in room %s", room_id) + if room_id in self._purges_in_progress_by_room: logger.warning( "[purge] not purging room %s as there's an ongoing purge running"