|
|
|
|
@ -178,10 +178,6 @@ func (w *Worker) Start() error {
|
|
|
|
|
controllerResolver := manual.NewBuilderWithScheme(scheme)
|
|
|
|
|
w.controllerResolver.Store(controllerResolver)
|
|
|
|
|
|
|
|
|
|
if err := w.startListeners(); err != nil {
|
|
|
|
|
return fmt.Errorf("error starting worker listeners: %w", err)
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
var err error
|
|
|
|
|
w.NodeeFileStorage, err = nodeefile.NewFileStorage(w.baseContext,
|
|
|
|
|
nodeefile.WithBaseDirectory(w.conf.RawConfig.Worker.StoragePath))
|
|
|
|
|
@ -189,6 +185,10 @@ func (w *Worker) Start() error {
|
|
|
|
|
return err
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if err := w.startListeners(); err != nil {
|
|
|
|
|
return fmt.Errorf("error starting worker listeners: %w", err)
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
nodeCreds, err := types.NewNodeCredentials(w.baseContext, w.NodeeFileStorage)
|
|
|
|
|
if err != nil {
|
|
|
|
|
return fmt.Errorf("error generating new node creds: %w", err)
|
|
|
|
|
|