dexorder/backend
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

finalize transactions fix

Browse Source
This commit is contained in:
Tim
2024-04-15 17:54:44 -04:00
parent ce50c9adaf
commit 1f4f5693eb
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/dexorder/order/executionhandler.py
View File

@@ -29,8 +29,8 @@ class TrancheExecutionHandler (TransactionHandler):
async def complete_transaction(self, job: TransactionJob) -> None: async def complete_transaction(self, job: TransactionJob) -> None:
req: TrancheExecutionRequest = job.request req: TrancheExecutionRequest = job.request
tk = TrancheKey(req.vault, req.order_index, req.tranche_index) tk = TrancheKey(req.vault, req.order_index, req.tranche_index)
log.debug(f'execution request {tk} no longer in-flight') log.debug(f'completing execution request {tk}')
del inflight_execution_requests[tk] # no longer in-flight del inflight_execution_requests[tk]
TrancheExecutionHandler() # map 'te' to a TrancheExecutionHandler TrancheExecutionHandler() # map 'te' to a TrancheExecutionHandler

2
src/dexorder/transaction.py
View File

@@ -118,7 +118,7 @@ async def handle_transaction_receipts():
def finalize_transactions(_fork: Fork, diffs: list[DiffEntryItem]): 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.chain == current_chain.get(),
TransactionJob.state == TransactionJobState.Sent TransactionJob.state == TransactionJobState.Sent
)).all()) )).all())