21364862659

Committed 26 Jan 2026 04:13PM UTC coverage: 73.492% (-15.0%) from 88.463%

Build # 21364862659

Build Type

push

github

Committed by

web-flow

Commit Message

Merge f981517ee into a84e19f3e

Run Details

4253 of 5787 relevant lines covered (73.49%)

55.69 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

43.48

/crud/common/batching_utils.lua

local errors = require('errors')
local dev_checks = require('crud.common.dev_checks')
local sharding_utils = require('crud.common.sharding.utils')

local NotPerformedError = errors.new_class('NotPerformedError', {capture_stack = false})

local batching_utils = {}

batching_utils.stop_on_error_msg = "Operation with tuple was not performed"
batching_utils.rollback_on_error_msg = "Operation with tuple was rollback"

function batching_utils.construct_sharding_hash_mismatch_errors(err_msg, tuples)
    dev_checks('string', 'table')

    local errs = {}

    for _, tuple in ipairs(tuples) do
        local err_obj = sharding_utils.ShardingHashMismatchError:new(err_msg)
        err_obj.operation_data = tuple
        table.insert(errs, err_obj)
    end

    return errs
end

function batching_utils.complement_batching_errors(errs, err_msg, tuples)
    dev_checks('table', 'string', 'table')

    for _, tuple in ipairs(tuples) do
        local err_obj = NotPerformedError:new(err_msg)
        err_obj.operation_data = tuple
        table.insert(errs, err_obj)
    end

    return errs
end

return batching_utils

1	local errors = require('errors')	19✔
2	local dev_checks = require('crud.common.dev_checks')	19✔
3	local sharding_utils = require('crud.common.sharding.utils')	19✔
4
5	local NotPerformedError = errors.new_class('NotPerformedError', {capture_stack = false})	19✔
6
7	local batching_utils = {}	19✔
8
9	batching_utils.stop_on_error_msg = "Operation with tuple was not performed"	19✔
10	batching_utils.rollback_on_error_msg = "Operation with tuple was rollback"	19✔
11
12	function batching_utils.construct_sharding_hash_mismatch_errors(err_msg, tuples)	19✔
13	dev_checks('string', 'table')	×
14
15	local errs = {}	×
16
17	for _, tuple in ipairs(tuples) do	×
18	local err_obj = sharding_utils.ShardingHashMismatchError:new(err_msg)	×
19	err_obj.operation_data = tuple	×
20	table.insert(errs, err_obj)	×
21	end
22
23	return errs	×
24	end
25
26	function batching_utils.complement_batching_errors(errs, err_msg, tuples)	19✔
27	dev_checks('table', 'string', 'table')	×
28
29	for _, tuple in ipairs(tuples) do	×
30	local err_obj = NotPerformedError:new(err_msg)	×
31	err_obj.operation_data = tuple	×
32	table.insert(errs, err_obj)	×
33	end
34
35	return errs	×
36	end
37
38	return batching_utils	19✔

tarantool / crud / 21364862659

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous