Skip to content

Insufficient test coverage of batched_parmap #104

New issue
New issue
Open
#105
Open
Insufficient test coverage of batched_parmap#104
#105
@atapin

Description

@atapin
atapin
opened on Jul 4, 2024

Line 47 is supposed to check if trailing chunks of batches are processed, but it lacks for proper coverage.

offchain/offchain/concurrency.py

Lines 42 to 53 in 85aa49f

def batched_parmap(fn: Callable, args: list, batch_size: int = 10) -> list: # type: ignore[type-arg] # noqa: E501
results = []
i, j = 0, 0
while i < len(args):
i, j = i + batch_size, i
if len(args) > i:
batch = args[j:i]
else:
batch = args[j:]
res = parmap(fn, batch)
results += res
return results

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions