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: