diff --git a/src/backend/distributed/sql/udfs/citus_nodes/13.1-1.sql b/src/backend/distributed/sql/udfs/citus_nodes/13.1-1.sql index 3f7116ac7..4d129d79e 100644 --- a/src/backend/distributed/sql/udfs/citus_nodes/13.1-1.sql +++ b/src/backend/distributed/sql/udfs/citus_nodes/13.1-1.sql @@ -2,14 +2,14 @@ SET search_path = 'pg_catalog'; DROP VIEW IF EXISTS pg_catalog.citus_nodes; CREATE OR REPLACE VIEW citus.citus_nodes AS -SELECT - nodename, - nodeport, - CASE +SELECT + nodename, + nodeport, + CASE WHEN groupid = 0 THEN 'coordinator' ELSE 'worker' - END AS role, - isactive AS active + END AS role, + isactive AS active FROM pg_dist_node; ALTER VIEW citus.citus_nodes SET SCHEMA pg_catalog; diff --git a/src/backend/distributed/sql/udfs/citus_nodes/latest.sql b/src/backend/distributed/sql/udfs/citus_nodes/latest.sql index 3f7116ac7..4d129d79e 100644 --- a/src/backend/distributed/sql/udfs/citus_nodes/latest.sql +++ b/src/backend/distributed/sql/udfs/citus_nodes/latest.sql @@ -2,14 +2,14 @@ SET search_path = 'pg_catalog'; DROP VIEW IF EXISTS pg_catalog.citus_nodes; CREATE OR REPLACE VIEW citus.citus_nodes AS -SELECT - nodename, - nodeport, - CASE +SELECT + nodename, + nodeport, + CASE WHEN groupid = 0 THEN 'coordinator' ELSE 'worker' - END AS role, - isactive AS active + END AS role, + isactive AS active FROM pg_dist_node; ALTER VIEW citus.citus_nodes SET SCHEMA pg_catalog; diff --git a/src/test/regress/mitmscripts/structs.py b/src/test/regress/mitmscripts/structs.py index 2be3a6a2e..f799662d8 100644 --- a/src/test/regress/mitmscripts/structs.py +++ b/src/test/regress/mitmscripts/structs.py @@ -137,18 +137,21 @@ class Message: class SharedMessage(Message, metaclass=MessageMeta): "A message which could be sent by either the frontend or the backend" + _msgtypes = dict() _classes = dict() class FrontendMessage(Message, metaclass=MessageMeta): "A message which will only be sent be a backend" + _msgtypes = dict() _classes = dict() class BackendMessage(Message, metaclass=MessageMeta): "A message which will only be sent be a frontend" + _msgtypes = dict() _classes = dict()