From 4eafa40ff2fa189698465a4c7df073c0a3bada7f Mon Sep 17 00:00:00 2001 From: Bernardo Meurer Date: Tue, 14 Aug 2018 00:05:00 -0300 Subject: [PATCH] Revert to sequential behavior for Python 2 --- beetsplug/absubmit.py | 14 +++++++++----- 1 file changed, 9 insertions(+), 5 deletions(-) diff --git a/beetsplug/absubmit.py b/beetsplug/absubmit.py index d5cca4619..4487da76c 100644 --- a/beetsplug/absubmit.py +++ b/beetsplug/absubmit.py @@ -26,8 +26,7 @@ import subprocess import tempfile import sys -from concurrent import futures - +from multiprocessing.pool import ThreadPool from distutils.spawn import find_executable import requests @@ -107,10 +106,15 @@ class AcousticBrainzSubmitPlugin(plugins.BeetsPlugin): def command(self, lib, opts, args): # Get items from arguments items = lib.items(ui.decargs(args)) - - with futures.ThreadPoolExecutor() as executor: + if sys.version_info[0] < 3: for item in items: - executor.submit(self.analyze_submit, (item)) + self.analyze_submit(item) + else: + # Create threadpool + pool = ThreadPool() + pool.map(self.analyze_submit, items) + pool.close() + pool.join() def analyze_submit(self, item): analysis = self._get_analysis(item)