txn.execute doesn't return cursors
This commit is contained in:
parent
d76c058eea
commit
884fb88e28
|
@ -441,12 +441,12 @@ class ApplicationServiceTransactionStore(SQLBaseStore):
|
||||||
def _get_oldest_unsent_txn(self, txn, service):
|
def _get_oldest_unsent_txn(self, txn, service):
|
||||||
# Monotonically increasing txn ids, so just select the smallest
|
# Monotonically increasing txn ids, so just select the smallest
|
||||||
# one in the txns table (we delete them when they are sent)
|
# one in the txns table (we delete them when they are sent)
|
||||||
result = txn.execute(
|
txn.execute(
|
||||||
"SELECT * FROM application_services_txns WHERE as_id=?"
|
"SELECT * FROM application_services_txns WHERE as_id=?"
|
||||||
" ORDER BY txn_id ASC LIMIT 1",
|
" ORDER BY txn_id ASC LIMIT 1",
|
||||||
(service.id,)
|
(service.id,)
|
||||||
)
|
)
|
||||||
rows = self.cursor_to_dict(result)
|
rows = self.cursor_to_dict(txn)
|
||||||
if not rows:
|
if not rows:
|
||||||
return None
|
return None
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue