From a79d758a0e8a7963e0e1d142906f14805db97c5c Mon Sep 17 00:00:00 2001
From: crusaderky <crusaderky@gmail.com>
Date: Fri, 1 May 2026 13:40:01 +0100
Subject: [PATCH] Clean up deprecated Prometheus metrics

---
 distributed/http/worker/prometheus/core.py        | 9 ---------
 distributed/http/worker/tests/test_worker_http.py | 1 -
 docs/source/prometheus.rst                        | 3 ---
 3 files changed, 13 deletions(-)

diff --git a/distributed/http/worker/prometheus/core.py b/distributed/http/worker/prometheus/core.py
index b6d7172c72b..3b3084e4f30 100644
--- a/distributed/http/worker/prometheus/core.py
+++ b/distributed/http/worker/prometheus/core.py
@@ -52,15 +52,6 @@ def collect(self) -> Iterator[Metric]:
                 tasks.add_metric([state], n)
         yield tasks
 
-        yield GaugeMetricFamily(
-            self.build_name("concurrent_fetch_requests"),
-            (
-                "Deprecated: This metric has been renamed to transfer_incoming_count.\n"
-                "Number of open fetch requests to other workers"
-            ),
-            value=ws.transfer_incoming_count,
-        )
-
         if self.server.monitor.monitor_gil_contention:
             yield CounterMetricFamily(
                 self.build_name("gil_contention"),
diff --git a/distributed/http/worker/tests/test_worker_http.py b/distributed/http/worker/tests/test_worker_http.py
index 039a3012fd4..4375e8e15fd 100644
--- a/distributed/http/worker/tests/test_worker_http.py
+++ b/distributed/http/worker/tests/test_worker_http.py
@@ -35,7 +35,6 @@ async def test_prometheus(c, s, a):
         a.http_server.port, prefix="dask_worker_"
     )
     expected_metrics = {
-        "dask_worker_concurrent_fetch_requests",
         "dask_worker_latency_seconds",
         "dask_worker_memory_bytes",
         "dask_worker_spill_bytes_total",
diff --git a/docs/source/prometheus.rst b/docs/source/prometheus.rst
index a38c85f0221..07943053571 100644
--- a/docs/source/prometheus.rst
+++ b/docs/source/prometheus.rst
@@ -191,9 +191,6 @@ dask_worker_transfer_outgoing_count
     Number of open data transfers to other workers
 dask_worker_transfer_outgoing_count_total
     Total number of data transfers to other workers since the worker was started
-dask_worker_concurrent_fetch_requests
-    **Deprecated:** This metric has been renamed to
-    ``dask_worker_transfer_incoming_count``.
 dask_worker_tick_count_total
     Total number of ticks observed since the server started
 dask_worker_tick_duration_maximum_seconds