From dcfd6be9d72fedc03f266867c4c649a63a683bbc Mon Sep 17 00:00:00 2001 From: Naresh Kumar D Date: Mon, 25 Mar 2024 09:36:31 +0530 Subject: [PATCH] Update osw_validator.py updates the validation logic to thread --- src/osw_validator.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/src/osw_validator.py b/src/osw_validator.py index fdece3a..2b9a34b 100644 --- a/src/osw_validator.py +++ b/src/osw_validator.py @@ -9,6 +9,7 @@ from .validation import Validation from .models.queue_message_content import Upload, ValidationResult from .config import Settings +import threading logging.basicConfig() logger = logging.getLogger('OSW_VALIDATOR') @@ -40,7 +41,9 @@ def process(message) -> None: if message is not None: queue_message = QueueMessage.to_dict(message) upload_message = Upload.data_from(queue_message) - self.validate(upload_message) + process_thread = threading.Thread(target=self.validate, args=[upload_message]) + process_thread.start() + # self.validate(upload_message) self.listening_topic.subscribe(subscription=self.subscription_name, callback=process)