@@ -14,10 +14,3 @@ |
||
| 14 | 14 | public function getBody(): string |
| 15 | 15 | { |
| 16 | 16 | return <<<LUA |
| 17 | - box.begin() |
|
| 18 | - local creator = mapper_find_or_create('job_queue', 'hash_status', { hash, 'r' }, tuple, 1, 1) |
|
| 19 | - box.commit() |
|
| 20 | - return creator |
|
| 21 | - LUA; |
|
| 22 | - } |
|
| 23 | -} |
|
@@ -14,10 +14,3 @@ |
||
| 14 | 14 | public function getBody(): string |
| 15 | 15 | { |
| 16 | 16 | return <<<LUA |
| 17 | - box.begin() |
|
| 18 | - local creator = mapper_find_or_create('job_queue', 'hash_status', { hash, 'r' }, tuple, 1, 1) |
|
| 19 | - box.commit() |
|
| 20 | - return creator |
|
| 21 | - LUA; |
|
| 22 | - } |
|
| 23 | -} |
|
@@ -14,14 +14,3 @@ |
||
| 14 | 14 | public function getBody(): string |
| 15 | 15 | { |
| 16 | 16 | return <<<LUA |
| 17 | - box.begin() |
|
| 18 | - local tuples = box.space.job_queue.index.status_id:select({'r'}, { limit = 1}) |
|
| 19 | - if #tuples > 0 then |
|
| 20 | - local request = box.space.job_queue:update(tuples[1].id, {{'=', 2, 't'}}) |
|
| 21 | - box.commit() |
|
| 22 | - return request |
|
| 23 | - end |
|
| 24 | - box.rollback() |
|
| 25 | - LUA; |
|
| 26 | - } |
|
| 27 | -} |
|
@@ -14,14 +14,3 @@ |
||
| 14 | 14 | public function getBody(): string |
| 15 | 15 | { |
| 16 | 16 | return <<<LUA |
| 17 | - box.begin() |
|
| 18 | - local tuples = box.space.job_queue.index.status_id:select({'r'}, { limit = 1}) |
|
| 19 | - if #tuples > 0 then |
|
| 20 | - local request = box.space.job_queue:update(tuples[1].id, {{'=', 2, 't'}}) |
|
| 21 | - box.commit() |
|
| 22 | - return request |
|
| 23 | - end |
|
| 24 | - box.rollback() |
|
| 25 | - LUA; |
|
| 26 | - } |
|
| 27 | -} |
|