Core & Internals: Fixing missing scalars()

rucio · Mar 8, 2024 · 7c7bcf1 · 7c7bcf1
1 parent fa7fb8b
commit 7c7bcf1
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/lib/rucio/core/rule.py b/lib/rucio/core/rule.py
@@ -2210,7 +2210,7 @@ def update_rules_for_lost_replica(scope, name, rse_id, nowait=False, *, session:
              models.ReplicaLock.name == name,
              models.ReplicaLock.rse_id == rse_id)
     ).with_for_update(nowait=nowait)
-    locks = session.execute(stmt).all()
+    locks = session.execute(stmt).scalars().all()
 
     stmt = select(
         models.RSEFileAssociation
@@ -2826,7 +2826,7 @@ def examine_rule(rule_id, *, session: "Session"):
                 ).order_by(
                     desc(models.RequestHistory.created_at)
                 )
-                transfers = session.execute(stmt).all()
+                transfers = session.execute(stmt).scalars().all()
                 transfer_cnt = len(transfers)
                 # Get the error of the last request that has been tried and also the SOURCE used for the last request
                 last_error, last_source, last_time, sources = None, None, None, []