Skip to content

Pipeline Concurrency#17402

Merged
hutuxian merged 6 commits intoPaddlePaddle:developfrom
hutuxian:pipeline
Jun 11, 2019
Merged

Pipeline Concurrency#17402
hutuxian merged 6 commits intoPaddlePaddle:developfrom
hutuxian:pipeline

Conversation

@hutuxian
Copy link
Contributor

Add the pipeline concurrency function

@CLAassistant
Copy link

CLAassistant commented May 14, 2019

CLA assistant check
All committers have signed the CLA.

@hutuxian hutuxian force-pushed the pipeline branch 5 times, most recently from db9ed40 to 112eb21 Compare May 17, 2019 06:15
Copy link
Member

Choose a reason for hiding this comment

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

I've fixed some bugs of dense tensor Resize, maybe you need to adapt the changes later.

Copy link
Member

Choose a reason for hiding this comment

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

I fixed some bugs here, maybe you can merge from develop.

Copy link
Member

Choose a reason for hiding this comment

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

why do you have to add reserved_size?

Copy link
Member

Choose a reason for hiding this comment

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

what is HTJ?

Copy link
Member

Choose a reason for hiding this comment

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

great, thanks for your fix.

Copy link
Member

Choose a reason for hiding this comment

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

workers_ here should be documented more clearly.

Copy link
Member

Choose a reason for hiding this comment

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

scope_queues_ should be documented clearly, this is a very important data structure in your design.

Copy link
Member

Choose a reason for hiding this comment

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

not sure whether this matches the newest API, please check and merge diff.

@hutuxian hutuxian force-pushed the pipeline branch 2 times, most recently from 0b4e590 to 848c376 Compare May 21, 2019 03:42
@hutuxian hutuxian force-pushed the pipeline branch 7 times, most recently from 6821ce2 to 379560b Compare June 3, 2019 12:48
@hutuxian hutuxian force-pushed the pipeline branch 2 times, most recently from ca7276d to aa6c2c9 Compare June 10, 2019 10:54
hutuxian added 5 commits June 10, 2019 19:48
- cpp: pipeline_trainer & section_worker
- python: PipelineOptimizer
Add a new datafeed type: PrivateInstantDataFeed
test=develop
add start_cpu_core_id and param_need_sync in proto
update the stream in sync functor
test=develop
model is gnn
test=develop
@hutuxian hutuxian force-pushed the pipeline branch 3 times, most recently from de105c9 to 3a997b1 Compare June 10, 2019 14:28
add API.spec
test=develop
Copy link
Collaborator

@gavin1332 gavin1332 left a comment

Choose a reason for hiding this comment

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

code review have be done in the offline

Copy link
Contributor

@xsrobin xsrobin left a comment

Choose a reason for hiding this comment

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

LGTM

Copy link
Contributor

@luotao1 luotao1 left a comment

Choose a reason for hiding this comment

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

LG for api.spec

@hutuxian hutuxian merged commit 969e637 into PaddlePaddle:develop Jun 11, 2019
hutuxian added a commit to hutuxian/Paddle that referenced this pull request Jun 11, 2019
test=release/1.5

Add Pipeline Concurrency Train Mode:
- Cpp: pipeline_trainer & section_worker
- Python: PipelineOptimizer
- Add a new data_feed type: PrivateInstantDataFeed
- Add a test demo of pipeline trainer and the test model is gnn
- Do not support win32 now
hutuxian added a commit that referenced this pull request Jun 17, 2019
cherry-pick for (#17402)

Add Pipeline Concurrency Train Mode:
- Cpp: pipeline_trainer & section_worker
- Python: PipelineOptimizer
- Add a new data_feed type: PrivateInstantDataFeed
- Add a test demo of pipeline trainer and the test model is gnn
- Do not support win32 now
@hutuxian hutuxian deleted the pipeline branch March 5, 2020 07:52
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.

6 participants