Function wrapper

beets/metadata_plugins.py:89–108

(*args, **kwargs)

    @wraps(func)
    def wrapper(*args, **kwargs) -> Iterator[Ret]:
        # Run plugin methods concurrently for faster I/O-bound lookups.
        with ThreadPoolExecutor() as executor:
            futures = {
                executor.submit(
                    # Evaluate iterator with list such that results are ready when
                    # future.result() is called.
                    materialize,
                    plugin,
                    method_name,
                    *args,
                    **kwargs,
                ): plugin
                for plugin in find_metadata_source_plugins()
            }

            for future in as_completed(futures):
                plugin = futures[future]
                with maybe_handle_plugin_error(plugin, method_name):
                    yield from filter(None, future.result())

    return wrapper