Archives/tubearchivist
2
0
Fork 0
mirror of https://github.com/tubearchivist/tubearchivist synced 2024-11-19 15:25:51 +00:00
Code Issues Projects Releases Wiki Activity

add contains to RedisQueue

Browse Source
This commit is contained in:
simon 2022-12-12 18:01:02 +07:00
parent 3b3d151ec3
commit 2753ce93a2
No known key found for this signature in database
GPG Key ID: 2C15AA5E89985DD4
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
tubearchivist/home/src/ta/ta_redis.py
View File

@ -114,6 +114,11 @@ class RedisQueue(RedisBase):
all_elements = [i.decode() for i in result] all_elements = [i.decode() for i in result]
return all_elements return all_elements
def contains(self, element):
"""check if element is in list"""
result = self.conn.execute_command("LPOS", self.key, element)
return result is not None
def add_list(self, to_add): def add_list(self, to_add):
"""add list to queue""" """add list to queue"""
self.conn.execute_command("RPUSH", self.key, *to_add) self.conn.execute_command("RPUSH", self.key, *to_add)