From 9f358602ed3a8329cdf9b065df4e1b0e38ae5ecc Mon Sep 17 00:00:00 2001 From: vishnuszipstack Date: Fri, 26 Jul 2024 13:50:23 +0530 Subject: [PATCH 1/2] limiting processed file pushing to mrq --- backend/workflow_manager/endpoint/destination.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/backend/workflow_manager/endpoint/destination.py b/backend/workflow_manager/endpoint/destination.py index ca55d8526..352a65712 100644 --- a/backend/workflow_manager/endpoint/destination.py +++ b/backend/workflow_manager/endpoint/destination.py @@ -153,6 +153,8 @@ def handle_output( file_name=file_name, error=error, result=result, meta_data=meta_data ) elif connection_type == WorkflowEndpoint.ConnectionType.MANUALREVIEW: + if file_history: + return result = self.get_result(file_history) meta_data = self.get_metadata(file_history) self._push_to_queue( From 3683c110390e506d06cb494c5721034b63256c9e Mon Sep 17 00:00:00 2001 From: vishnuszipstack Date: Fri, 26 Jul 2024 15:29:51 +0530 Subject: [PATCH 2/2] added log info while skip pushing data to MRQ --- backend/workflow_manager/endpoint/destination.py | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/backend/workflow_manager/endpoint/destination.py b/backend/workflow_manager/endpoint/destination.py index 352a65712..aafb5d624 100644 --- a/backend/workflow_manager/endpoint/destination.py +++ b/backend/workflow_manager/endpoint/destination.py @@ -154,6 +154,10 @@ def handle_output( ) elif connection_type == WorkflowEndpoint.ConnectionType.MANUALREVIEW: if file_history: + logger.info( + f"Already processed result, skip adding to MRQ. " + f"WorkflowID{workflow.id}" + ) return result = self.get_result(file_history) meta_data = self.get_metadata(file_history)