Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Wrong report of currently executed tasks when using --nworkers N, with N>1 #8544

Open
jonded94 opened this issue Feb 29, 2024 · 0 comments
Open

Comments

@jonded94
Copy link

jonded94 commented Feb 29, 2024

Describe the issue:

Executing a Dask worker with >1 processes (aka --nworkers [N] with N>1) will lead to wrong data in both the worker dashboard and especially the Prometheus metrics at /metrics.

Minimal Complete Verifiable Example:

Running a dask worker in k8s with this config

spec:
  containers:
  - args:
    - dask
    - worker
    - --name
    - $(DASK_WORKER_NAME)
    - --dashboard
    - --dashboard-address
    - "8788"
    - --nworkers
    - "15"
    - --nthreads
    - "1"

and fully loading all worker processes (i.e. 15 running tasks per worker) will lead to these worker dashboard numbers.
image

So it's reporting that it is only executing 1 task while actually, this is currently churning through 15 tasks. Also, the Prometheus metrics will say this

# HELP dask_worker_tasks Number of tasks at worker.
# TYPE dask_worker_tasks gauge
dask_worker_tasks{state="memory"} 3.0
dask_worker_tasks{state="executing"} 1.0
# HELP dask_worker_concurrent_fetch_requests Deprecated: This metric has been renamed to transfer_incoming_count.\nNumber of open fetch requests to other workers
# TYPE dask_worker_concurrent_fetch_requests gauge
dask_worker_concurrent_fetch_requests 0.0
# HELP dask_worker_threads Number of worker threads
# TYPE dask_worker_threads gauge
dask_worker_threads 1.0

Aggregating these metrics with Grafana will give wildy wrong numbers (out by a factor of 15 in my case).

Environment:

  • Dask version: 2024.2.1
  • Python version: 3.9.18
  • Operating System: Linux
  • Install method (conda, pip, source): poetry
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

No branches or pull requests

1 participant