Database: Add query hint to update_replicas query; Fix #4204

rucio · Jan 5, 2021 · 30bfcc4 · 30bfcc4
1 parent 0eea5ea
commit 30bfcc4
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/lib/rucio/core/replica.py b/lib/rucio/core/replica.py
@@ -1831,6 +1831,7 @@ def list_and_mark_unlocked_replicas(limit, bytes=None, rse_id=None, delay_second
                                            models.RSEFileAssociation.rse_id == rse_id))
     for chunk in chunks(replica_clause, 100):
         session.query(models.RSEFileAssociation).filter(or_(*chunk)).\
+            with_hint(models.RSEFileAssociation, text="INDEX(REPLICAS REPLICAS_PK)", dialect_name='oracle').\
             update({'updated_at': datetime.utcnow(), 'state': ReplicaState.BEING_DELETED}, synchronize_session=False)
 
     return rows