diff options
| author | martinko | 2014-10-29 08:41:14 +0000 |
|---|---|---|
| committer | martinko | 2014-10-29 08:41:14 +0000 |
| commit | 00586ba49f73737d239e3ea17febd3136ea6e87e (patch) | |
| tree | a7a3f3c8f7023750c215b674558a6a97f30dc10d /sql | |
| parent | ce44959442968b3a641dfe462739597290d28b8e (diff) | |
| parent | 808ebf8db0f0837f2d89d037eda24f93048d18a3 (diff) | |
Merge branch 'master' of https://github.com/markokr/skytools into hotfix/3.2.5
Diffstat (limited to 'sql')
| -rw-r--r-- | sql/pgq_node/functions/pgq_node.demote_root.sql | 3 | ||||
| -rw-r--r-- | sql/pgq_node/functions/pgq_node.promote_branch.sql | 3 |
2 files changed, 4 insertions, 2 deletions
diff --git a/sql/pgq_node/functions/pgq_node.demote_root.sql b/sql/pgq_node/functions/pgq_node.demote_root.sql index d3f68d03..a1c67aaf 100644 --- a/sql/pgq_node/functions/pgq_node.demote_root.sql +++ b/sql/pgq_node/functions/pgq_node.demote_root.sql @@ -36,7 +36,8 @@ declare begin select node_type, worker_name into n_type, w_name from pgq_node.node_info - where queue_name = i_queue_name; + where queue_name = i_queue_name + for update; if not found then select 404, 'Node not initialized for queue: ' || i_queue_name into ret_code, ret_note; diff --git a/sql/pgq_node/functions/pgq_node.promote_branch.sql b/sql/pgq_node/functions/pgq_node.promote_branch.sql index 9e2c7a26..c19511a9 100644 --- a/sql/pgq_node/functions/pgq_node.promote_branch.sql +++ b/sql/pgq_node/functions/pgq_node.promote_branch.sql @@ -26,7 +26,8 @@ declare begin select node_name, node_type, worker_name into n_name, n_type, w_name from pgq_node.node_info - where queue_name = i_queue_name; + where queue_name = i_queue_name + for update; if not found then select 404, 'Node not initialized for queue: ' || i_queue_name into ret_code, ret_note; |