diff --git a/cluster/process.go b/cluster/process.go index 85cab534..e7d3c5f4 100644 --- a/cluster/process.go +++ b/cluster/process.go @@ -70,7 +70,7 @@ func (c *cluster) ProcessSetCommand(origin string, id app.ProcessID, command str return c.applyCommand(cmd) } - nodeid, err := c.manager.ProcessFindNodeID(id) + nodeid, err := c.store.ProcessGetNode(id) if err != nil { return fmt.Errorf("the process '%s' is not registered with any node: %w", id.String(), err) }