diff --git a/pkg/plugins/manager/process/process.go b/pkg/plugins/manager/process/process.go index 6ba85dbdb5f..e72b071123f 100644 --- a/pkg/plugins/manager/process/process.go +++ b/pkg/plugins/manager/process/process.go @@ -54,12 +54,13 @@ func (m *Manager) Start(ctx context.Context, pluginID string) error { m.log.Info("Plugin registered", "pluginID", p.ID) m.mu.Lock() + defer m.mu.Unlock() + if err := startPluginAndRestartKilledProcesses(ctx, p); err != nil { return err } p.Logger().Debug("Successfully started backend plugin process") - m.mu.Unlock() return nil }