diff options
| -rw-r--r-- | sql/pgq_node/functions/pgq_node.get_consumer_state.sql | 2 | ||||
| -rw-r--r-- | sql/pgq_node/functions/pgq_node.get_node_info.sql | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/sql/pgq_node/functions/pgq_node.get_consumer_state.sql b/sql/pgq_node/functions/pgq_node.get_consumer_state.sql index 548fed96..389d985a 100644 --- a/sql/pgq_node/functions/pgq_node.get_consumer_state.sql +++ b/sql/pgq_node/functions/pgq_node.get_consumer_state.sql @@ -33,7 +33,7 @@ create or replace function pgq_node.get_consumer_state( -- uptodate - if consumer has loaded last changes -- ---------------------------------------------------------------------- begin - select 200, 'Ok', n.node_type, n.node_name, s.last_tick_id, + select 100, 'Ok', n.node_type, n.node_name, s.last_tick_id, s.provider_node, p.node_location, s.paused, s.uptodate into ret_code, ret_note, node_type, node_name, completed_tick, provider_node, provider_location, paused, uptodate diff --git a/sql/pgq_node/functions/pgq_node.get_node_info.sql b/sql/pgq_node/functions/pgq_node.get_node_info.sql index 60719576..20978762 100644 --- a/sql/pgq_node/functions/pgq_node.get_node_info.sql +++ b/sql/pgq_node/functions/pgq_node.get_node_info.sql @@ -44,7 +44,7 @@ create or replace function pgq_node.get_node_info( declare sql text; begin - select 200, 'Ok', n.node_type, n.node_name, g.last_tick, + select 100, 'Ok', n.node_type, n.node_name, g.last_tick, c.node_type, c.queue_name, w.provider_node, l.node_location, n.worker_name, w.paused, w.uptodate, w.last_tick_id into ret_code, ret_note, node_type, node_name, global_watermark, |