skrd/musiclist-server
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix redis.zrange es inclusivo

Browse Source
This commit is contained in:
Daniel Cortes
2020-06-14 20:03:07 -04:00
parent 4beb7c07d4
commit f5411ae25d
2 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
fetcher/cache.py
View File

@@ -53,7 +53,7 @@ def get_discs_of_artist(mbid, limit, offset):
jobs.load_artist_on_cache.delay(mbid)
return None, 0
release_ids = redis.zrange(key_releases, offset, offset + limit)
release_ids = redis.zrange(key_releases, offset, offset + limit - 1)
keys = [f'release_group:{mbid}' for mbid in release_ids]
if redis.exists(*keys) != len(keys):
_log.debug('Aun no se cargan todas las release_groups del artista %s', mbid)
@@ -108,7 +108,7 @@ def get_releases_of_disc(mbid, limit, offset):
jobs.load_entities_of_release_group.delay(mbid)
return None, 0
release_ids = redis.zrange(key_releases, offset, offset + limit)
release_ids = redis.zrange(key_releases, offset, offset + limit - 1)
keys = [f'release:{mbid}' for mbid in release_ids]
if redis.exists(*keys) != len(keys):
_log.debug('Aun no se cargan todas las releases del disco %s', mbid)
@@ -215,7 +215,7 @@ def get_releases_of_recording(mbid, limit, offset):
jobs.load_entities_of_recording.delay(mbid)
return None, 0
release_ids = redis.zrange(releases_key, offset, offset + limit)
release_ids = redis.zrange(releases_key, offset, offset + limit - 1)
keys = [f'release:{mbid}' for mbid in release_ids]
if redis.exists(*keys) != len(keys):
_log.debug('No estan todas las releses')

8
fetcher/test.py
View File

@@ -125,7 +125,7 @@ class CacheTest(TestCase):
mock_redis.__contains__.assert_called_with('artist:mbid:release_groups')
mock_redis.get.assert_called_with('artist:mbid:release_groups:count')
mock_redis.zcard.assert_called_with('artist:mbid:release_groups')
mock_redis.zrange.assert_called_with('artist:mbid:release_groups', 0, 10)
mock_redis.zrange.assert_called_with('artist:mbid:release_groups', 0, 9)
mock_redis.exists.assert_called_with(*[f'release_group:{i}' for i in range(10)])
mock_jobs.load_artist_on_cache.delay.asert_called_once_with('mbid')
@@ -152,7 +152,7 @@ class CacheTest(TestCase):
mock_redis.__contains__.assert_called_with('artist:mbid:release_groups')
mock_redis.get.assert_called_with('artist:mbid:release_groups:count')
mock_redis.zcard.assert_called_with('artist:mbid:release_groups')
mock_redis.zrange.assert_called_with('artist:mbid:release_groups', 0, 10)
mock_redis.zrange.assert_called_with('artist:mbid:release_groups', 0, 9)
mock_redis.exists.assert_called_with(*[f'release_group:{i}' for i in range(10)])
mock_jobs.load_artist_on_cache.delay.assert_not_called()
@@ -270,7 +270,7 @@ class CacheTest(TestCase):
mock_redis.__contains__.assert_called_with('release_group:mbid:releases')
mock_redis.get.assert_called_with('release_group:mbid:releases:count')
mock_redis.zcard.assert_called_with('release_group:mbid:releases')
mock_redis.zrange.assert_called_with('release_group:mbid:releases', 0, 10)
mock_redis.zrange.assert_called_with('release_group:mbid:releases', 0, 9)
mock_redis.exists.assert_called_with(*[f'release:{id}' for id in range(10)])
mock_jobs.load_entities_of_release_group.delay.assert_called_with('mbid')
@@ -296,7 +296,7 @@ class CacheTest(TestCase):
mock_redis.__contains__.assert_called_with('release_group:mbid:releases')
mock_redis.get.assert_called_with('release_group:mbid:releases:count')
mock_redis.zcard.assert_called_with('release_group:mbid:releases')
mock_redis.zrange.assert_called_with('release_group:mbid:releases', 0, 10)
mock_redis.zrange.assert_called_with('release_group:mbid:releases', 0, 9)
mock_redis.exists.assert_called_with(*[f'release:{id}' for id in range(10)])
mock_jobs.load_entities_of_release_group.delay.assert_not_called()