-
Notifications
You must be signed in to change notification settings - Fork 120
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
vine: changes tasks_running to tasks_on_workers for display tables #3499
vine: changes tasks_running to tasks_on_workers for display tables #3499
Conversation
Hmm, I'm not sure if this has the intended effect. Here is what I see: 1 - The manager knows how many tasks are in the RUNNING state (sent to the worker) by just looking at Currently # 3 is the thing displayed to users in What do you think? |
Ah, yes, directly looking at q->running_table would be better. |
Actually, the pr should be ready. Note that w->current_tasks is only used when asking for the information per worker. For the rest, tasks_on_workers already is set from q->running_table in get_stats. |
So instead of changing the status tools to display |
RTM |
The changes to |
This pr would make it so that it shows |
No, I just want the plain meaning used throughout: The reported I understand that the meaning of "running" is a little fuzzy because it means "the manager sent it to the worker but the worker may not have received or acted on it yet". but that's true of any property in a distributed system. |
Ok, should I remove the |
No reason to remove stats reported to the catalog, they may still come in handy, I think. |
They will have the same value, as they are both set to the size of q->tasks_running. Is that ok? |
Sorry, they are different, my mistake. on_workers also has tasks with results. |
bfa15fd
to
112ebda
Compare
Proposed changes
tasks_on_workers is accurate for what the manager knows. tasks_running depends on worker messages that may be stale.
Post-change actions
make test
Run local tests prior to pushing.make format
Format source code to comply with lint policies. Note that some lint errors can only be resolved manually (e.g., Python)make lint
Run lint on source code prior to pushing.