absolute memory usage for now

Author: gjoseph92

distributed/scheduler.py

@@ -3252,7 +3252,7 @@ def worker_objective_ignore_deps(self, ws: WorkerState) -> tuple[float, float]:
 
         Minimize worker occupancy. If a tie then break with data storage.
         """
-        return (ws.occupancy / ws.nthreads, ws.nbytes / (ws.memory_limit or 1))
+        return (ws.occupancy / ws.nthreads, ws.nbytes)
 
     def add_replica(self, ts: TaskState, ws: WorkerState):
         """Note that a worker holds a replica of a task with state='memory'"""

distributed/tests/test_scheduler.py

@@ -517,6 +517,9 @@ async def test_decide_worker_memory_tiebreaker_idle_cluster(c, s, *workers):
     assert first(last_ts.who_has) is not first(big_ts.who_has)
 
 
+@pytest.mark.skip(
+    "Not yet implemented: https://github.com/dask/distributed/issues/7266"
+)
 @gen_cluster(
     client=True,
     nthreads=[],