Parallel map fue una mala idea~

fetcher/medium.py

@@ -6,7 +6,6 @@ traducción.
 """
 from math import ceil
 from country_list import countries_for_language
-from utils import parallel_map
 import fetcher.musicbrainz as mb
 
 
@@ -177,7 +176,7 @@ def get_discs_of_artist(mbid, limit, page):
 
     return {
         'paginate': paginate(mb_discs['release_group_count'], limit, page),
-        'discs': parallel_map(mb_discs['release_groups'], map_disc)
+        'discs': [map_disc(disc) for disc in mb_discs['release_groups']]
     }
 
 
@@ -189,7 +188,7 @@ def get_artist_of_disc(mbid, limit, page):
 
     return {
         'paginate': paginate(mb_artists.get('artist_count', 0), limit, page),
-        'artists': parallel_map(mb_artists['artists'], map_artist)
+        'artists': [map_artist(artist) for artist in mb_artists['artists']]
     }
 
 
@@ -215,7 +214,7 @@ def get_releases_of_disc(mbid, limit, page):
 
     return {
         'paginate': paginate(mb_releases.get('release_count', 0), limit, page),
-        'releases': parallel_map(mb_releases.get('releases'), map_release)
+        'releases': [map_release(release) for release in mb_releases.get('releases')]
     }
 
 
@@ -227,7 +226,7 @@ def get_artist_of_release(mbid, limit, page):
 
     return {
         'paginate': paginate(mb_artists.get('artist_count', 0), limit, page),
-        'artists': parallel_map(mb_artists.get('artists'), map_artist)
+        'artists': [map_artist(artist) for artist in mb_artists.get('artists')]
     }
 
 
@@ -254,7 +253,7 @@ def get_recordings_of_release(mbid, limit, page):
 
     return {
         'paginate': paginate(mb_recordings.get('recording_count', 0), limit, page),
-        'recordings': parallel_map(mb_recordings['recordings'], map_recording)
+        'recordings': [map_recording(recording) for recording in mb_recordings['recordings']]
     }
 
 
@@ -267,7 +266,7 @@ def get_release_of_recording(mbid, limit, page):
 
     return {
         'paginate': paginate(mb_releases.get('release_count', 0), limit, page),
-        'releases': parallel_map(mb_releases.get('releases'), map_release)
+        'releases': [map_release(release) for release in mb_releases.get('releases')]
     }
 
 
@@ -280,7 +279,7 @@ def get_artist_of_recording(mbid, limit, page):
 
     return {
         'paginate': paginate(mb_artists.get('artist_count', 0), limit, page),
-        'artists': parallel_map(mb_artists['artists'], map_artist)
+        'artists': [map_artist(artist) for artist in mb_artists['artists']]
     }
 
 
@@ -334,7 +333,7 @@ def search_artist(query, limit, page):
 
     return {
         'paginate': paginate(mb_artists['count'], limit, page),
-        'artists': parallel_map(mb_artists['artists'], map_artist)
+        'artists': [map_artist(artist) for artist in mb_artists['artists']]
     }
 
 
@@ -345,7 +344,7 @@ def search_disc(query, limit, page):
 
     return {
         'paginate': paginate(mb_discs['count'], limit, page),
-        'discs': parallel_map(mb_discs['release_groups'], map_disc)
+        'discs': [map_disc(disc) for disc in mb_discs['release_groups']]
     }
 
 
@@ -356,7 +355,7 @@ def search_release(query, limit, page):
 
     return {
         'paginate': paginate(mb_releases['count'], limit, page),
-        'releases': parallel_map(mb_releases['releases'], map_release)
+        'releases': [map_release(release) for release in mb_releases['releases']]
     }
 
 
@@ -367,5 +366,5 @@ def search_recording(query, limit, page):
 
     return {
         'paginate': paginate(mb_recording['count'], limit, page),
-        'recordings': parallel_map(mb_recording['recordings'], map_recording)
+        'recordings': [map_recording(recording) for recording in mb_recording['recordings']]
     }

pre-commit.sh

@@ -13,9 +13,6 @@ pip install -r requirements.txt -r requirements-dev.txt
 
 LINT_RESULT=$?
 
-STASHES=$(git stash list)
+git stash pop -q
-if [[ $STASHES == "$STASH_NAME" ]]; then
-  git stash pop -q
-fi
 
 exit $LINT_RESULT

utils/__init__.py

@@ -79,9 +79,3 @@ def sanitize_keys(dictionary):
             replace_key(dictionary, key, new_key)
     return dictionary
 
-
-def parallel_map(items, function):
-    """Ejecuta una función sobre cada elemento de una lista de items en paralelo utilizando
-    una Pool del modulo multiprocessing.dummy """
-    with Pool() as pool:
-        return pool.map(function, items)