|
|
|
@ -20,8 +20,6 @@ from paddle.fluid.optimizer import PipelineOptimizer as PO
|
|
|
|
|
from .meta_optimizer_base import MetaOptimizerBase
|
|
|
|
|
from .common import OpRole, OP_ROLE_KEY, OP_ROLE_VAR_KEY, CollectiveHelper, is_update_op, is_loss_grad_op, is_backward_op, is_optimizer_op
|
|
|
|
|
|
|
|
|
|
__all__ = ["PipelineOptimizer"]
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
class PipelineHelper(CollectiveHelper):
|
|
|
|
|
def __init__(self, role_maker, nrings=1, wait_port='6174'):
|
|
|
|
|