diff options
| author | Will Hunt <will@half-shot.uk> | 2019-03-20 16:32:44 +0000 |
|---|---|---|
| committer | Will Hunt <will@half-shot.uk> | 2019-03-20 16:32:44 +0000 |
| commit | f4b3f2066f7d1dc6105eb0a981e02963259d424f (patch) | |
| tree | 2c5d9fa938b225dbd64185e1d0f5036389e7df25 | |
| parent | Log over appservice push path (diff) | |
| download | synapse-f4b3f2066f7d1dc6105eb0a981e02963259d424f.tar.xz | |
Logging around get_new_events_for_appservice
| -rw-r--r-- | synapse/storage/appservice.py | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/synapse/storage/appservice.py b/synapse/storage/appservice.py index 31248d5e06..7ab85c9fc5 100644 --- a/synapse/storage/appservice.py +++ b/synapse/storage/appservice.py @@ -340,6 +340,8 @@ class ApplicationServiceTransactionWorkerStore(ApplicationServiceWorkerStore, def get_new_events_for_appservice(self, current_id, limit): """Get all new evnets""" + logger.info("call get_new_events_for_appservice(%s, %s)", current_id, limit) + def get_new_events_for_appservice_txn(txn): sql = ( "SELECT e.stream_ordering, e.event_id" @@ -365,8 +367,12 @@ class ApplicationServiceTransactionWorkerStore(ApplicationServiceWorkerStore, "get_new_events_for_appservice", get_new_events_for_appservice_txn, ) + logger.info("call get_new_events_for_appservice len(event_ids) = %s", len(event_ids)) + events = yield self._get_events(event_ids) + logger.info("call get_new_events_for_appservice len(event_ids) = %s", len(events)) + defer.returnValue((upper_bound, events)) |