From efdff894bcb38addf91cfceafa885e25e14b7fc4 Mon Sep 17 00:00:00 2001
From: DESPRES Damien <ddespres@neogeo.fr>
Date: Thu, 14 Oct 2021 22:27:47 +0200
Subject: [PATCH] fix count value
---
workers/doc_enricher.py | 1 +
workers/doc_processor.py | 2 +-
2 files changed, 2 insertions(+), 1 deletion(-)
diff --git a/workers/doc_enricher.py b/workers/doc_enricher.py
index 5f1b18b..fc9c7ee 100644
--- a/workers/doc_enricher.py
+++ b/workers/doc_enricher.py
@@ -178,6 +178,7 @@ def enrich_docs( channel, method, properties, body ):
msg['body'] = doc_page
the_body = msgpack.packb(msg, use_bin_type=True, default=encode_datetime)
+ dest_queue = channel.queue_declare(queue=doc_pages_to_process_qn, durable=True, arguments={'x-message-ttl' : cfg['rabbitmq']['ttl']}, passive=True)
q_len = dest_queue.method.message_count
logging.info('Queue Size is %i for %s...' % ( q_len, doc_pages_to_process_qn))
while q_len > 50:
diff --git a/workers/doc_processor.py b/workers/doc_processor.py
index df73a8d..bffb7ab 100644
--- a/workers/doc_processor.py
+++ b/workers/doc_processor.py
@@ -166,7 +166,7 @@ def process_docs( channel, method, properties, body ):
the_body = msgpack.packb(msg, use_bin_type=True)
-
+ dest_queue = channel.queue_declare(queue=docs_to_index_qn, durable=True, arguments={'x-message-ttl' : cfg['rabbitmq']['ttl']}, passive=True)
q_len = dest_queue.method.message_count
logging.info('Queue Size is %i for %s...' % ( q_len, docs_to_index_qn))
while q_len > 50:
--
GitLab