Skip to content
Merged
Show file tree
Hide file tree
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
7 changes: 2 additions & 5 deletions python/ray/dashboard/modules/reporter/reporter_agent.py
Original file line number Diff line number Diff line change
Expand Up @@ -1312,8 +1312,8 @@ def generate_worker_stats_record(self, worker_stats: List[dict]) -> List[Record]

for stat in worker_stats:
cmdline = stat.get("cmdline")
# All ray processes start with ray::
if cmdline and len(cmdline) > 0 and cmdline[0].startswith("ray::"):
# collect both worker and driver stats
if cmdline and len(cmdline) > 0:
proc_name = cmdline[0]
proc_name_to_stats[proc_name].append(stat)

Expand All @@ -1323,9 +1323,6 @@ def generate_worker_stats_record(self, worker_stats: List[dict]) -> List[Record]
or stat.get("gpu_utilization", 0) > 0
):
gpu_worker_proc_names.add(proc_name)
# We will lose worker stats that don't follow the ray worker proc
# naming convention. Theoretically, there should be no data loss here
# because all worker processes are renamed to ray::.

records = []

Expand Down
1 change: 1 addition & 0 deletions python/ray/tests/test_metrics_agent.py
Original file line number Diff line number Diff line change
Expand Up @@ -886,6 +886,7 @@ def verify_components():
components.add(sample.labels["Component"])
print(components)
assert {
sys.executable, # driver process
"raylet",
"agent",
"ray::Actor",
Expand Down