Skip to content
Snippets Groups Projects
Commit fde74dd3 authored by Vincent Garonne's avatar Vincent Garonne
Browse files

[RUCIO-000] Fix

Change-Id: Ia05b12a7940add9318a3be007ab2f9d6bfd177a5
parent bddbdbd8
No related branches found
No related tags found
No related merge requests found
...@@ -897,6 +897,10 @@ def list_unlocked_replicas(rse, limit, bytes=None, rse_id=None, worker_number=No ...@@ -897,6 +897,10 @@ def list_unlocked_replicas(rse, limit, bytes=None, rse_id=None, worker_number=No
if tombstone != OBSOLETE and needed_space is not None and total_bytes >= needed_space: if tombstone != OBSOLETE and needed_space is not None and total_bytes >= needed_space:
break break
if tombstone != OBSOLETE and total_files > limit:
break
if total_obsolete_files > 10000:
break
d = {'scope': scope, 'name': name, 'bytes': bytes} d = {'scope': scope, 'name': name, 'bytes': bytes}
rows.append(d) rows.append(d)
...@@ -906,12 +910,6 @@ def list_unlocked_replicas(rse, limit, bytes=None, rse_id=None, worker_number=No ...@@ -906,12 +910,6 @@ def list_unlocked_replicas(rse, limit, bytes=None, rse_id=None, worker_number=No
else: else:
total_obsolete_files += 1 total_obsolete_files += 1
if total_files == limit:
break
if total_obsolete_files == 10000:
break
return rows return rows
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment