diff options
| -rw-r--r-- | sql/pgq_node/functions/pgq_node.drop_node.sql | 11 |
1 files changed, 7 insertions, 4 deletions
diff --git a/sql/pgq_node/functions/pgq_node.drop_node.sql b/sql/pgq_node/functions/pgq_node.drop_node.sql index 708f6152..fbf13ae7 100644 --- a/sql/pgq_node/functions/pgq_node.drop_node.sql +++ b/sql/pgq_node/functions/pgq_node.drop_node.sql @@ -56,11 +56,14 @@ begin perform pgq.drop_queue(queue_name, true) from pgq.queue where queue_name = i_queue_name; - end if; - delete from pgq_node.node_location - where queue_name = i_queue_name - and node_name = i_node_name; + delete from pgq_node.node_location + where queue_name = i_queue_name; + else + delete from pgq_node.node_location + where queue_name = i_queue_name + and node_name = i_node_name; + end if; select 200, 'Node dropped' into ret_code, ret_note; return; |