Completed
Push — master ( 3f30e7...37b632 )
by Dmitry
08:21
created
src/Procedure/JobQueue/Cast.php 2 patches
Doc Comments   -7 removed lines patch added patch discarded remove patch
@@ -14,10 +14,3 @@
 block discarded – undo
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
-}
Please login to merge, or discard this patch.
Unused Use Statements   -7 removed lines patch added patch discarded remove patch
@@ -14,10 +14,3 @@
 block discarded – undo
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
-}
Please login to merge, or discard this patch.
src/Procedure/JobQueue/Take.php 2 patches
Doc Comments   -11 removed lines patch added patch discarded remove patch
@@ -14,14 +14,3 @@
 block discarded – undo
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
-}
Please login to merge, or discard this patch.
Unused Use Statements   -11 removed lines patch added patch discarded remove patch
@@ -14,14 +14,3 @@
 block discarded – undo
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
-}
Please login to merge, or discard this patch.