-
Notifications
You must be signed in to change notification settings - Fork 6.3k
[data.dashboard.x/01] fix operator state #52188
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
Conversation
"state": DatasetState.FINISHED.name | ||
if op_state.num_completed_tasks == op.num_outputs_total() | ||
and op.num_outputs_total() > 0 | ||
else state, |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
After this PR https://github.com/ray-project/ray/pull/52226/files, we can simplify this.
"state": DatasetState.FINISHED.name | |
if op_state.num_completed_tasks == op.num_outputs_total() | |
and op.num_outputs_total() > 0 | |
else state, | |
"state": DatasetState.FINISHED.name if op.execution_complete() else state, |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
lol nice, i'll wait for it then; does it always FINISHED once completed or can be FAILED as well?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
No running tasks doesn't entail that operator is complete
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
ok, let's merge the other PR then I'll follow @raulchen's approach
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
only finished. we currently don't have failed state per op.
Signed-off-by: can <[email protected]>
Signed-off-by: can <[email protected]>
a00b847
to
1250bed
Compare
@raulchen , @alexeykudinkin : updated, can you review, thankks |
Currently the operator state just mimics the entire dataset state, aka. they show as running even though they already finished. Fix it so that if the number of progress already equals to number of total, move it to FINISHED state. Test: - CI <img width="572" alt="Screenshot 2025-04-09 at 2 33 21 PM" src="https://github.com/user-attachments/assets/236ce1f8-05a8-4ab6-b8bf-2c651375c33e" /> --------- Signed-off-by: can <[email protected]>
Currently the operator state just mimics the entire dataset state, aka. they show as running even though they already finished. Fix it so that if the number of progress already equals to number of total, move it to FINISHED state. Test: - CI <img width="572" alt="Screenshot 2025-04-09 at 2 33 21 PM" src="https://github.com/user-attachments/assets/236ce1f8-05a8-4ab6-b8bf-2c651375c33e" /> --------- Signed-off-by: can <[email protected]>
Currently the operator state just mimics the entire dataset state, aka. they show as running even though they already finished. Fix it so that if the number of progress already equals to number of total, move it to FINISHED state. Test: - CI <img width="572" alt="Screenshot 2025-04-09 at 2 33 21 PM" src="https://github.com/user-attachments/assets/236ce1f8-05a8-4ab6-b8bf-2c651375c33e" /> --------- Signed-off-by: can <[email protected]> Signed-off-by: zhaoch23 <[email protected]>
Currently the operator state just mimics the entire dataset state, aka. they show as running even though they already finished. Fix it so that if the number of progress already equals to number of total, move it to FINISHED state.
Test: