From 02562f1c5031be1ed6d87cb18aa1db3768eb72db Mon Sep 17 00:00:00 2001 From: Lei PAN Date: Mon, 24 Nov 2025 09:02:30 +0100 Subject: [PATCH] ignore model filter --- workers/link_validator_with_provided_list.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/workers/link_validator_with_provided_list.py b/workers/link_validator_with_provided_list.py index 558cb0d..8fb6bf6 100644 --- a/workers/link_validator_with_provided_list.py +++ b/workers/link_validator_with_provided_list.py @@ -31,7 +31,7 @@ def filter_link_pojo_list_with_model(_received_dict, link_to_validate_list): _model = _received_dict["model"] print("link list size before filter = {}".format(len(link_to_validate_list))) _links_filtered_by_model = list(filter(lambda link_pojo: link_pojo.model == _model, link_to_validate_list)) - # _links_filtered_by_model = link_to_validate_list + _links_filtered_by_model = link_to_validate_list print("link list size after filter = {}".format(len(_links_filtered_by_model))) if len(_links_filtered_by_model) > 0: return _links_filtered_by_model @@ -188,8 +188,8 @@ class LinkValidatorWithProvidedList(threading.Thread): ch.basic_reject(delivery_tag=method.delivery_tag, requeue=True) else: print("will ack") - print("will wait for 40s") - time.sleep(40) + print("will wait for 10s") + time.sleep(10) ch.basic_ack(delivery_tag=method.delivery_tag) else: print("empty list, will republish message")