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

job cleanup fix

Browse Source
This commit is contained in:
tim
2025-02-26 13:39:00 -04:00
parent 6c76a9efd7
commit 31a2edd0c6
1 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/dexorder/transactions.py
View File

@@ -172,20 +172,26 @@ async def handle_transaction_receipts():
log.warning(f'ignoring transaction request with bad type "{job.request.type}"') log.warning(f'ignoring transaction request with bad type "{job.request.type}"')
else: else:
await handler.complete_transaction(job, receipt) await handler.complete_transaction(job, receipt)
end_job(job)
try: try:
await handler.release_account(accounts_in_flight.pop(job.tx_id)) await handler.release_account(accounts_in_flight.pop(job.tx_id))
except KeyError: except KeyError:
pass pass
end_job(job)
def end_job(job): def end_job(job):
ended_jobs.append(job) ended_jobs.append(job)
def cleanup_jobs(): async def cleanup_jobs():
for job in ended_jobs: for job in ended_jobs:
log.debug(f'ending job {job.id}') log.debug(f'ending job {job.id}')
if job.tx_id in accounts_in_flight:
try:
handler = TransactionHandler.of(job.request.type)
await handler.release_account(accounts_in_flight.pop(job.tx_id))
except KeyError:
log.warning(f'ignoring transaction request with bad type "{job.request.type}"')
in_flight.discard((job.request.type, job.request.key)) in_flight.discard((job.request.type, job.request.key))
db.session.delete(job) db.session.delete(job)
ended_jobs.clear() ended_jobs.clear()