tweak

dask · Aug 31, 2021 · dfb1a09 · dfb1a09
1 parent 4785546
commit dfb1a09
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/distributed/active_memory_manager.py b/distributed/active_memory_manager.py
@@ -154,7 +154,7 @@ def _run_policies(self) -> None:
         ts: TaskState
         nreplicas: int
 
-        for policy in self.policies:
+        for policy in list(self.policies):  # a policy may remove itself
             policy_gen = policy.run()
             ws = None
             while True: