diff --git a/go/pkg/api/provider.go b/go/pkg/api/provider.go index 0c422f5..ee6faa7 100644 --- a/go/pkg/api/provider.go +++ b/go/pkg/api/provider.go @@ -720,7 +720,7 @@ func (p *ProcessProvider) registerProcessEvents() { p.actions.Do(func() { coreApp.RegisterAction(func(_ *core.Core, msg core.Message) core.Result { p.forwardProcessEvent(msg) - return core.Result{OK: true} + return core.Ok(nil) }) }) } diff --git a/go/service.go b/go/service.go index 26a84db..cbacbb0 100644 --- a/go/service.go +++ b/go/service.go @@ -96,7 +96,7 @@ func (s *Service) OnStartup(context.Context) core.Result { c.RegisterAction(s.handleTask) } }) - return core.Result{OK: true} + return core.Ok(nil) } // OnShutdown implements core.Stoppable. @@ -822,12 +822,12 @@ func (s *Service) handleTask(c *core.Core, task core.Message) core.Result { } proc := result.Value.(*Process) return core.Ok(proc.Info()) - case TaskProcessRun: - result := s.RunWithOptions(c.Context(), RunOptions(m)) - if !result.OK { - return result - } - return core.Ok(result.Value) + case TaskProcessRun: + result := s.RunWithOptions(c.Context(), RunOptions(m)) + if !result.OK { + return result + } + return core.Ok(result.Value) case TaskProcessKill: switch { case m.ID != "":