diff --git a/src/dexorder/order/executionhandler.py b/src/dexorder/order/executionhandler.py
index d6a75ea..38d4107 100644
--- a/src/dexorder/order/executionhandler.py
+++ b/src/dexorder/order/executionhandler.py
@@ -29,8 +29,8 @@ class TrancheExecutionHandler (TransactionHandler):
     async def complete_transaction(self, job: TransactionJob) -> None:
         req: TrancheExecutionRequest = job.request
         tk = TrancheKey(req.vault, req.order_index, req.tranche_index)
-        log.debug(f'execution request {tk} no longer in-flight')
-        del inflight_execution_requests[tk]  # no longer in-flight
+        log.debug(f'completing execution request {tk}')
+        del inflight_execution_requests[tk]
 
 
 TrancheExecutionHandler() # map 'te' to a TrancheExecutionHandler
diff --git a/src/dexorder/transaction.py b/src/dexorder/transaction.py
index 5dcdc7a..026403a 100644
--- a/src/dexorder/transaction.py
+++ b/src/dexorder/transaction.py
@@ -118,7 +118,7 @@ async def handle_transaction_receipts():
 
 
 def finalize_transactions(_fork: Fork, diffs: list[DiffEntryItem]):
-    open_txs = set(db.session.execute(select(TransactionJob.tx_id).where(
+    open_txs = set(db.session.scalars(select(TransactionJob.tx_id).where(
         TransactionJob.chain == current_chain.get(),
         TransactionJob.state == TransactionJobState.Sent
     )).all())