From 388f90421de704b8542a3a51b881e96b3014cfaa Mon Sep 17 00:00:00 2001 From: Navid Zarepak Date: Mon, 14 Jun 2021 14:28:46 +0430 Subject: [PATCH] removed `noderole = 'wait_primary'` from `getPrimaryWorkers` (#1) --- core/core.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/core.go b/core/core.go index 3e324c0..3283b67 100644 --- a/core/core.go +++ b/core/core.go @@ -98,7 +98,7 @@ func GetCoordinators(dbname string) ([]*Node, error) { func (d *database) getPrimaryWorkers() ([]*Worker, error) { var workers []*Worker err := d.db.Select(&workers, - `SELECT * from pg_dist_node where noderole = 'primary' or noderole = 'wait_primary';`) + `SELECT * from pg_dist_node where noderole = 'primary';`) return workers, err }