diff --git a/lyric_search_new/sources/redis_cache.py b/lyric_search_new/sources/redis_cache.py index 5859c3a..e338e5d 100644 --- a/lyric_search_new/sources/redis_cache.py +++ b/lyric_search_new/sources/redis_cache.py @@ -108,7 +108,8 @@ class RedisCache: Returns: None """ - redis_mapping = { + try: + redis_mapping = { 'id': sqlite_id, 'src': lyr_result.src, 'date_retrieved': time.time(), @@ -120,15 +121,16 @@ class RedisCache: 'tags': '(none)', 'liked': 0, } - newkey = f"lyrics:000{sqlite_id}" - jsonset = await self.redis_client.json().set(newkey, Path.root_path(), - redis_mapping) - if not jsonset: - raise RedisException(f"Failed to store {lyr_result.artist} - {lyr_result.song} (SQLite id: {sqlite_id}):\n{jsonset}") - logging.info("Stored %s - %s (related SQLite Row ID: %s) to %s", - lyr_result.artist, lyr_result.song, sqlite_id, newkey) - await self.notifier.send("INFO", - f"Stored {lyr_result.artist} - {lyr_result.song} (related SQLite Row ID: {sqlite_id}) to {newkey}") - - - \ No newline at end of file + newkey = f"lyrics:000{sqlite_id}" + jsonset = await self.redis_client.json().set(newkey, Path.root_path(), + redis_mapping) + if not jsonset: + raise RedisException(f"Failed to store {lyr_result.artist} - {lyr_result.song} (SQLite id: {sqlite_id}):\n{jsonset}") + logging.info("Stored %s - %s (related SQLite Row ID: %s) to %s", + lyr_result.artist, lyr_result.song, sqlite_id, newkey) + await self.notifier.send("INFO", + f"Stored {lyr_result.artist} - {lyr_result.song} (related SQLite Row ID: {sqlite_id}) to {newkey}") + except Exception as e: + await self.notifier.send(f"ERROR @ {__file__}", + f"Failed to store {lyr_result.artist} - {lyr_result.song}\ + (SQLite id: {sqlite_id}) to Redis:\n{str(e)}") \ No newline at end of file