From 0cb4fa7880794c56dcafc11ba7f6c3eefcda3a0e Mon Sep 17 00:00:00 2001 From: Evgeni Pandurski Date: Mon, 1 Jul 2024 20:59:42 +0300 Subject: [PATCH] Fixed a nasty locking problem with WorkerTurn --- swpt_trade/procedures/transfers.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/swpt_trade/procedures/transfers.py b/swpt_trade/procedures/transfers.py index 8358f81..39397d6 100644 --- a/swpt_trade/procedures/transfers.py +++ b/swpt_trade/procedures/transfers.py @@ -103,7 +103,7 @@ def process_candidate_offer_signal( WorkerTurn.query .filter_by(turn_id=turn_id, phase=2, worker_turn_subphase=5) .options(load_only(WorkerTurn.collection_deadline)) - .with_for_update(read=True, skip_locked=True) + .with_for_update(read=True) .one_or_none() ) if not worker_turn: