up
This commit is contained in:
parent
e5d79928b3
commit
9edc954426
@ -63,7 +63,6 @@ queue_name -> {
|
|||||||
async def is_task_already_done_or_exist(redis: RedisClient, link: str):
|
async def is_task_already_done_or_exist(redis: RedisClient, link: str):
|
||||||
messages = await redis.get_task_done_queue()
|
messages = await redis.get_task_done_queue()
|
||||||
temp = [json.loads(msg) for msg in messages]
|
temp = [json.loads(msg) for msg in messages]
|
||||||
print(temp)
|
|
||||||
tasks = [
|
tasks = [
|
||||||
msg for msg in temp
|
msg for msg in temp
|
||||||
if msg["link"] == link
|
if msg["link"] == link
|
||||||
|
Loading…
Reference in New Issue
Block a user