diff --git a/engine_group.go b/engine_group.go index 5e659aaf..734056c2 100644 --- a/engine_group.go +++ b/engine_group.go @@ -51,6 +51,8 @@ func NewEngineGroup(args1 interface{}, args2 interface{}, policies ...GroupPolic for i := 0; i < len(slaves); i++ { slaves[i].engineGroup = &eg } + eg.Engine = master + eg.slaves = slaves return &eg, nil } return nil, ErrParamsType