@@ -2,7 +2,6 @@ |
||
2 | 2 | |
3 | 3 | namespace Test; |
4 | 4 | |
5 | -use Basis\Converter; |
|
6 | 5 | use Basis\Event; |
7 | 6 | use Basis\Http; |
8 | 7 | use Basis\Test; |
@@ -8,8 +8,6 @@ |
||
8 | 8 | use Exception; |
9 | 9 | use Tarantool\Mapper\Entity; |
10 | 10 | use Tarantool\Mapper\Plugin\Procedure; |
11 | -use Tarantool\Mapper\Procedure\FindOrCreate; |
|
12 | -use Tarantool\Mapper\Repository; |
|
13 | 11 | |
14 | 12 | class Executor |
15 | 13 | { |
@@ -14,14 +14,3 @@ |
||
14 | 14 | public function getBody(): string |
15 | 15 | { |
16 | 16 | return <<<LUA |
17 | - box.begin() |
|
18 | - for i, t in box.space.job_queue.index.status_id:pairs('transfered') do |
|
19 | - local result = box.space.job_result.index.service_hash:count({t.recipient, t.hash}) |
|
20 | - if result > 0 then |
|
21 | - box.space.job_queue:delete(t.id) |
|
22 | - end |
|
23 | - end |
|
24 | - box.commit() |
|
25 | - LUA; |
|
26 | - } |
|
27 | -} |
@@ -14,14 +14,3 @@ |
||
14 | 14 | public function getBody(): string |
15 | 15 | { |
16 | 16 | return <<<LUA |
17 | - box.begin() |
|
18 | - for i, t in box.space.job_queue.index.status_id:pairs('transfered') do |
|
19 | - local result = box.space.job_result.index.service_hash:count({t.recipient, t.hash}) |
|
20 | - if result > 0 then |
|
21 | - box.space.job_queue:delete(t.id) |
|
22 | - end |
|
23 | - end |
|
24 | - box.commit() |
|
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({'new'}, { limit = 1}) |
|
19 | - if #tuples > 0 then |
|
20 | - local request = box.space.job_queue:update(tuples[1].id, {{'=', 2, 'processing'}}) |
|
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({'new'}, { limit = 1}) |
|
19 | - if #tuples > 0 then |
|
20 | - local request = box.space.job_queue:update(tuples[1].id, {{'=', 2, 'processing'}}) |
|
21 | - box.commit() |
|
22 | - return request |
|
23 | - end |
|
24 | - box.rollback() |
|
25 | - LUA; |
|
26 | - } |
|
27 | -} |
@@ -14,9 +14,3 @@ |
||
14 | 14 | public function getBody(): string |
15 | 15 | { |
16 | 16 | return <<<LUA |
17 | - return box.space.job_result:pairs() |
|
18 | - :filter(function(r) return r.service ~= service end) |
|
19 | - :totable() |
|
20 | - LUA; |
|
21 | - } |
|
22 | -} |
@@ -14,9 +14,3 @@ |
||
14 | 14 | public function getBody(): string |
15 | 15 | { |
16 | 16 | return <<<LUA |
17 | - return box.space.job_result:pairs() |
|
18 | - :filter(function(r) return r.service ~= service end) |
|
19 | - :totable() |
|
20 | - LUA; |
|
21 | - } |
|
22 | -} |