diff options
author | Kegan Dougal <kegan@matrix.org> | 2015-03-10 10:04:20 +0000 |
---|---|---|
committer | Kegan Dougal <kegan@matrix.org> | 2015-03-10 10:04:20 +0000 |
commit | db1fbc6c6fb23ab92dd712aa60f0ff46ea76b42c (patch) | |
tree | 41ebbc0487f24ec3af9210ef1e0633a35d8ee43c /synapse/storage | |
parent | Remove unused import (diff) | |
download | synapse-db1fbc6c6fb23ab92dd712aa60f0ff46ea76b42c.tar.xz |
Fix remaining scheduler bugs. Add more informative logging.
Diffstat (limited to 'synapse/storage')
-rw-r--r-- | synapse/storage/appservice.py | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/synapse/storage/appservice.py b/synapse/storage/appservice.py index fe347dfd3c..c4b4f56c5d 100644 --- a/synapse/storage/appservice.py +++ b/synapse/storage/appservice.py @@ -293,6 +293,8 @@ class ApplicationServiceStore(SQLBaseStore): services = {} for res in results: as_token = res["token"] + if as_token is None: + continue if as_token not in services: # add the service services[as_token] = { @@ -516,11 +518,10 @@ class ApplicationServiceTransactionStore(SQLBaseStore): # Monotonically increasing txn ids, so just select the smallest # one in the txns table (we delete them when they are sent) result = txn.execute( - "SELECT *,MIN(txn_id) FROM application_services_txns WHERE as_id=?", + "SELECT MIN(txn_id), * FROM application_services_txns WHERE as_id=?", (service.id,) ) entry = self.cursor_to_dict(result)[0] - if not entry or entry["txn_id"] is None: # the min(txn_id) part will force a row, so entry may not be None return None |