diff --git a/engineapi/instance_manager.go b/engineapi/instance_manager.go index 178eb09696..abef7fc547 100644 --- a/engineapi/instance_manager.go +++ b/engineapi/instance_manager.go @@ -195,6 +195,10 @@ func (c *InstanceManagerClient) EngineProcessCreate(e *longhorn.Engine, volumeFr } } + if engineCLIAPIVersion >= 9 { + args = append(args, "--instance-name", e.ObjectMeta.Name) + } + for _, addr := range e.Status.CurrentReplicaAddressMap { args = append(args, "--replica", GetBackendReplicaURL(addr)) } @@ -235,6 +239,10 @@ func (c *InstanceManagerClient) ReplicaProcessCreate(replica *longhorn.Replica, } } + if engineCLIAPIVersion >= 9 { + args = append(args, "--instance-name", replica.ObjectMeta.Name) + } + binary := filepath.Join(types.GetEngineBinaryDirectoryForReplicaManagerContainer(replica.Spec.EngineImage), types.EngineBinaryName) replicaProcess, err := c.grpcClient.ProcessCreate(