-
Notifications
You must be signed in to change notification settings - Fork 5.8k
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] Add PENDING_ACTOR_TASK_ARGS_FETCH and PENDING_ACTOR_TASK_ORDERING_OR_CONCURRENCY TaskStatus #48242
Conversation
…CONCURRENCY TaskStatus Signed-off-by: Jiajun Yao <jeromeyjj@gmail.com>
FYI: @alexeykudinkin |
// The actor task is fetching arguments. This happens after the actor worker | ||
// receives the task and the actor task has object refs as arguments. | ||
PENDING_ACTOR_TASK_ARGS_FETCH = 6; | ||
// The actor task is waiting due to ordering or concurrency constraints. | ||
PENDING_ACTOR_TASK_ORDERING_OR_CONCURRENCY = 7; |
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.
Wait, why are these specific to actor tasks @jjyao?
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.
For normal task, args fetch is before SUBMITTED_TO_WORKER and happens in raylet and is PENDING_ARGS_FETCH
. Also normal task, you don't need to wait for concurrency, each a worker process only runs one normal task at a time.
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.
Understood. It's a bit odd to encode the entity name into the state, but i see your point there.
…ING_OR_CONCURRENCY TaskStatus (ray-project#48242) Signed-off-by: Jiajun Yao <jeromeyjj@gmail.com>
…ING_OR_CONCURRENCY TaskStatus (ray-project#48242) Signed-off-by: Jiajun Yao <jeromeyjj@gmail.com>
…ING_OR_CONCURRENCY TaskStatus (ray-project#48242) Signed-off-by: Jiajun Yao <jeromeyjj@gmail.com> Signed-off-by: mohitjain2504 <mohit.jain@dream11.com>
Why are these changes needed?
Currently we don't know which status an actor task has in between
SUBMITTED_TO_WORKER
ANDRUNNING
.Related issue number
Checks
git commit -s
) in this PR.scripts/format.sh
to lint the changes in this PR.method in Tune, I've added it in
doc/source/tune/api/
under thecorresponding
.rst
file.