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

[fleet_executor] Python side fleet executor and task node #38290

Conversation

FeixLiu
Copy link
Contributor

@FeixLiu FeixLiu commented Dec 20, 2021

PR types

Others

PR changes

Others

Describe

task node from python side class

Use these codes to test mp_dp_sharding:

from paddle.distributed.fleet.fleet_executor_utils import TaskNode
task_node = TaskNode(
    program=main_program.clone(),
    cur_rank=0,
    max_run_times=1,
    max_slot_times=1)
main_program._pipeline_opt = {}
main_program._pipeline_opt['fleet_opt'] = {
   'section_program': main_program,
   'tasks': [task_node],
   'task_id_to_rank': {task_node.task_id(): fleet.worker_index()}
}
main_program._pipeline_opt['section_program'] = main_program

Screen Shot 2021-12-20 at 7 37 42 PM

@paddle-bot-old
Copy link

Thanks for your contribution!
Please wait for the result of CI firstly. See Paddle CI Manual for details.

python/paddle/fluid/executor.py Outdated Show resolved Hide resolved
python/paddle/fluid/executor.py Outdated Show resolved Hide resolved
Copy link
Contributor

@wangxicoding wangxicoding left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM

@wangxicoding wangxicoding merged commit a4afb97 into PaddlePaddle:develop Dec 21, 2021
@FeixLiu FeixLiu deleted the python_side_fleet_executor_and_task_node branch December 21, 2021 08:59
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

None yet

2 participants