diff --git a/tubearchivist/home/src/index/reindex.py b/tubearchivist/home/src/index/reindex.py index 6982d6cb..441f033b 100644 --- a/tubearchivist/home/src/index/reindex.py +++ b/tubearchivist/home/src/index/reindex.py @@ -195,11 +195,13 @@ class ReindexManual(ReindexBase): if not values: return - RedisQueue("reindex:ta_video").add_list(values) + queue_name = self.REINDEX_CONFIG["video"]["queue_name"] + RedisQueue(queue_name).add_list(values) def _add_channels(self, values): """add list of channels to reindex queue""" - RedisQueue("reindex:ta_channel").add_list(values) + queue_name = self.REINDEX_CONFIG["channel"]["queue_name"] + RedisQueue(queue_name).add_list(values) if self.extract_videos: for channel_id in values: @@ -208,7 +210,8 @@ class ReindexManual(ReindexBase): def _add_playlists(self, values): """add list of playlists to reindex queue""" - RedisQueue("reindex:ta_playlist").add_list(values) + queue_name = self.REINDEX_CONFIG["playlist"]["queue_name"] + RedisQueue(queue_name).add_list(values) if self.extract_videos: for playlist_id in values: diff --git a/tubearchivist/home/src/ta/ta_redis.py b/tubearchivist/home/src/ta/ta_redis.py index cba148aa..94859e2c 100644 --- a/tubearchivist/home/src/ta/ta_redis.py +++ b/tubearchivist/home/src/ta/ta_redis.py @@ -104,6 +104,17 @@ class RedisQueue(RedisBase): dynamically interact with queues in redis using sorted set - low score number is first in queue - add new items with high score number + + queue names in use: + download:channel channels during download + download:playlist:full playlists during dl for full refresh + download:playlist:quick playlists during dl for quick refresh + download:video videos during downloads + index:comment videos needing comment indexing + reindex:ta_video reindex videos + reindex:ta_channel reindex channels + reindex:ta_playlist reindex playlists + """ def __init__(self, queue_name: str):