diff options
| -rw-r--r-- | sql/pgq_node/expected/pgq_node_test.out | 2 | ||||
| -rw-r--r-- | sql/pgq_node/functions/pgq_node.get_consumer_state.sql | 3 |
2 files changed, 4 insertions, 1 deletions
diff --git a/sql/pgq_node/expected/pgq_node_test.out b/sql/pgq_node/expected/pgq_node_test.out index 6b68660e..c2d3ab7a 100644 --- a/sql/pgq_node/expected/pgq_node_test.out +++ b/sql/pgq_node/expected/pgq_node_test.out @@ -309,7 +309,7 @@ select * from pgq_node.unregister_consumer('bqueue', 'random_consumer2'); select * from pgq_node.get_consumer_state('bqueue', 'random_consumer2'); ret_code | ret_note | node_type | node_name | completed_tick | provider_node | provider_location | paused | uptodate | cur_error ----------+-------------------------------------------+-----------+-----------+----------------+---------------+-------------------+--------+----------+----------- - 404 | Unknown consumer: bqueue/random_consumer2 | | | | | | | | + 404 | Unknown consumer: bqueue/random_consumer2 | branch | node2 | | | | | | (1 row) select * from pgq_node.get_node_info('bqueue'); 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 0d7e2bd6..624fd12b 100644 --- a/sql/pgq_node/functions/pgq_node.get_consumer_state.sql +++ b/sql/pgq_node/functions/pgq_node.get_consumer_state.sql @@ -42,6 +42,7 @@ begin if not found then select 404, 'Unknown queue: ' || i_queue_name into ret_code, ret_note; + return; end if; select s.last_tick_id, s.provider_node, s.paused, s.uptodate, s.cur_error into completed_tick, provider_node, paused, uptodate, cur_error @@ -51,6 +52,7 @@ begin if not found then select 404, 'Unknown consumer: ' || i_queue_name || '/' || i_consumer_name into ret_code, ret_note; + return; end if; select 100, 'Ok', p.node_location into ret_code, ret_note, provider_location @@ -60,6 +62,7 @@ begin if not found then select 404, 'Unknown provider node: ' || i_queue_name || '/' || provider_node into ret_code, ret_note; + return; end if; return; end; |