Function wrapper

common/wrapper.py:14–26

(*args, **kwargs)

    def decorator(func):
        @wraps(func)
        def wrapper(*args, **kwargs):

            try:
                self = args[0]
                nums = self.sc_number
            except:
                nums = n

            with ThreadPoolExecutor() as executor:
                futures = [executor.submit(func, *args, **kwargs) for _ in range(nums)]
                outputs = [future.result() for future in futures]
            output, statistics = combine_json(outputs, keys, mode)
            return output, statistics

        return wrapper