Parcourir la source

fix for redis queue checking

Avik Datta il y a 4 ans
Parent
commit
a6d3fccf0f
1 fichiers modifiés avec 6 ajouts et 2 suppressions
  1. 6 2
      igf_airflow/check_celery_queue.py

+ 6 - 2
igf_airflow/check_celery_queue.py

@@ -3,10 +3,14 @@ import redis
 def fetch_queue_list_from_redis_server(url):
   try:
     queue_list = list()
+    print(url)
+    print(redis.__version__)
     r = redis.from_url(url)
     for i in r.keys():
-      queue = i.decode() 
-      if not queue.startswith('_'):
+      queue = i.decode()
+      if not queue.startswith('_') and \
+         not queue.startswith('unacked'):
+        print(queue)
         q_len = r.llen(queue)
         queue_list.append({queue:q_len})
     return queue_list