Don't make False add-keys report to scheduler (#2421)

Fixes #2420
dask · Jul 15, 2019 · d493498 · d493498
1 parent 5b31a87
commit d493498
Showing 1 changed file with 0 additions and 5 deletions.
diff --git a/distributed/worker.py b/distributed/worker.py
@@ -1884,11 +1884,6 @@ def gather_dep(self, worker, dep, deps, total_nbytes, cause=None):
                 self.incoming_count += 1
 
                 self.log.append(("receive-dep", worker, list(response["data"])))
-
-                if response["data"]:
-                    self.batched_stream.send(
-                        {"op": "add-keys", "keys": list(response["data"])}
-                    )
             except EnvironmentError as e:
                 logger.exception("Worker stream died during communication: %s", worker)
                 self.log.append(("receive-dep-failed", worker))