Skip to content

Commit

Permalink
Add redis reader
Browse files Browse the repository at this point in the history
  • Loading branch information
gabriel-piles committed Nov 29, 2024
1 parent d528b7d commit a4331f9
Showing 1 changed file with 18 additions and 0 deletions.
18 changes: 18 additions & 0 deletions src/check_queues.py
Original file line number Diff line number Diff line change
@@ -0,0 +1,18 @@
from time import sleep

from rsmq import RedisSMQ

QUEUES_NAMES = ["development_ocr"]

if __name__ == "__main__":
for i in range(100):
for queue_name in QUEUES_NAMES:
try:
print(queue_name)
queue = RedisSMQ(host="localhost", qname=f"{queue_name}_tasks")
print(queue.getQueueAttributes().exec_command())
except:
pass
print()

sleep(5)

0 comments on commit a4331f9

Please sign in to comment.