Backup_Repos/beets
1
0
Fork 0
mirror of https://github.com/beetbox/beets.git synced 2025-12-29 20:12:33 +01:00
Code Issues Projects Releases Wiki Activity

Parallelized absubmit

Browse source
This commit is contained in:
Bernardo Meurer 2018-08-13 22:44:45 -03:00
parent bac8faad78
commit 22a6a0e6ef
No known key found for this signature in database
GPG key ID: E421C74191EA186C
1 changed files with 9 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
beetsplug/absubmit.py
View file

@ -25,6 +25,7 @@ import os
import subprocess
import tempfile
from multiprocessing import Pool
from distutils.spawn import find_executable
import requests
@ -102,12 +103,16 @@ class AcousticBrainzSubmitPlugin(plugins.BeetsPlugin):
return [cmd]
def command(self, lib, opts, args):
# Create threadpool
pool = Pool()
# Get items from arguments
items = lib.items(ui.decargs(args))
for item in items:
analysis = self._get_analysis(item)
if analysis:
self._submit_data(item, analysis)
pool.map(self.analyze_submit, items)
def analyze_submit(self, item):
analysis = self._get_analysis(item)
if analysis:
self._submit_data(item, analysis)
def _get_analysis(self, item):
mbid = item['mb_trackid']