From d827f6314809dc6c98bfb0c4b8e8f666ffa83b0d Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Kuba=20Podg=C3=B3rski?= Date: Tue, 9 Feb 2021 16:21:25 +0100 Subject: [PATCH] Fix ApplySchema API --- api.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/api.go b/api.go index 0fd7bcb0d..4906b80b8 100644 --- a/api.go +++ b/api.go @@ -1022,10 +1022,12 @@ func (api *API) ApplySchema(ctx context.Context, s *Schema, remote bool) error { } } } - if !remote { nodes := api.cluster.Nodes() for i, node := range nodes { + if node.ID == api.Node().ID { + continue + } err := api.server.defaultClient.PostSchema(ctx, &node.URI, s, true) if err != nil { return errors.Wrapf(err, "forwarding post schema to node %d of %d", i+1, len(nodes))