Remove in-transition call to release_key

dask · Mar 4, 2021 · d3d0aa8 · d3d0aa8
1 parent 47ada8e
commit d3d0aa8
Showing 1 changed file with 0 additions and 3 deletions.
diff --git a/distributed/worker.py b/distributed/worker.py
@@ -1711,9 +1711,6 @@ def transition_flight_fetch(self, ts, worker=None, runspec=None):
                 if dependent.state == "waiting":
                     self.data_needed.append(dependent.key)
 
-            if not ts.dependents:
-                self.release_key(ts.key, cause="transition flight->fetch")
-
         except Exception as e:
             logger.exception(e)
             if LOG_PDB: