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

[core] process commands are reported as "ray::IDLE" instead of the program name #31456

Closed
clarng opened this issue Jan 5, 2023 · 3 comments · Fixed by #36928
Closed

[core] process commands are reported as "ray::IDLE" instead of the program name #31456

clarng opened this issue Jan 5, 2023 · 3 comments · Fixed by #36928
Assignees
Labels
api-bug Bug in which APIs behavior is wrong bug Something that is supposed to be working; but isn't core Issues that should be addressed in Ray Core core-worker P1 Issue that should be fixed within a few weeks Ray 2.6 size:medium

Comments

@clarng
Copy link
Contributor

clarng commented Jan 5, 2023

What happened + What you expected to happen

when running top I notice the workers are named ray::IDLE even when they are executing:

e.g.

PID USER PR NI VIRT RES SHR S %CPU %MEM TIME+ COMMAND

168935 ray 35 15 12.0g 2.4g 72072 R 86.1 7.6 0:21.64 ray::IDLE
168378 ray 35 15 11.8g 1.6g 619068 R 79.8 5.2 0:29.01 ray::IDLE
168377 ray 35 15 11.6g 1.5g 619488 R 79.1 4.8 0:27.96 ray::IDLE
168380 ray 35 15 11.7g 1.6g 618816 R 76.2 5.1 0:29.20 ray::IDLE
168376 ray 35 15 11.8g 1.6g 618976 R 72.5 5.2 0:29.03 ray::IDLE
168379 ray 35 15 11.7g 1.5g 618724 R 70.9 5.0 0:28.61 ray::IDLE

I expect them to be named after the actual process command when the worker is moved from the pool to the task

Versions / Dependencies

master

Reproduction script

ds = ray.data.range(10000000, parallelism=100)

def transform_batch(list) -> list:
return list

ds = ds.map_batches(transform_batch).fully_executed()

Issue Severity

Medium: It is a significant difficulty but I can work around it.

@clarng clarng added bug Something that is supposed to be working; but isn't triage Needs triage (eg: priority, bug/not-bug, and owning component) labels Jan 5, 2023
@clarng
Copy link
Contributor Author

clarng commented Jan 5, 2023

cc @scv119

@clarng
Copy link
Contributor Author

clarng commented Jan 5, 2023

seems related to dataset as the command works for trainer

PID USER PR NI VIRT RES SHR S %CPU %MEM TIME+ COMMAND

168218 ray 35 15 12.1g 6.1g 5.9g S 99.0 19.7 14:19.02 ray::RayTrainWo
167599 ray 20 0 1725404 246528 27684 R 28.3 0.8 7:58.01 python

@hora-anyscale hora-anyscale added core Issues that should be addressed in Ray Core P1 Issue that should be fixed within a few weeks labels Jan 20, 2023
@hora-anyscale hora-anyscale removed the triage Needs triage (eg: priority, bug/not-bug, and owning component) label Jan 27, 2023
@scv119 scv119 added enhancement Request for new feature and/or capability core-worker labels Feb 16, 2023
@rkooo567 rkooo567 added Ray 2.4 Ray 2.5 api-bug Bug in which APIs behavior is wrong and removed Ray 2.4 labels Mar 24, 2023
@rickyyx
Copy link
Contributor

rickyyx commented Apr 3, 2023

I think we keep workers around after finishing the tasks, so they could show up IDLE while not running the task (or running between tasks)? What if you block in the transform_batch - do they still show up as idle?

@rkooo567 rkooo567 assigned rkooo567 and unassigned stephanie-wang Apr 10, 2023
@rkooo567 rkooo567 removed their assignment May 8, 2023
@rkooo567 rkooo567 added Ray 2.6 and removed Ray 2.5 labels May 8, 2023
@rkooo567 rkooo567 added size:medium and removed enhancement Request for new feature and/or capability labels Jun 2, 2023
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
api-bug Bug in which APIs behavior is wrong bug Something that is supposed to be working; but isn't core Issues that should be addressed in Ray Core core-worker P1 Issue that should be fixed within a few weeks Ray 2.6 size:medium
Projects
None yet
Development

Successfully merging a pull request may close this issue.

7 participants