removed noderole = 'wait_primary' from getPrimaryWorkers (#1)

Navid2zp · Jun 14, 2021 · 388f904 · 388f904
1 parent a1d00a6
commit 388f904
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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
 }