From b8c8aa94afef0549a97f373e35a430c375fc8770 Mon Sep 17 00:00:00 2001 From: ali Date: Tue, 14 Oct 2025 13:28:24 +0530 Subject: [PATCH] minor additions --- workers/shared/workflow/destination_connector.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/workers/shared/workflow/destination_connector.py b/workers/shared/workflow/destination_connector.py index 83f12380..ec4a5881 100644 --- a/workers/shared/workflow/destination_connector.py +++ b/workers/shared/workflow/destination_connector.py @@ -414,11 +414,11 @@ class WorkerDestinationConnector: ) return True # Lock acquired and stage set successfully - except FileExecutionStageException as stage_error: + except FileExecutionStageException: # Stage transition failed (shouldn't happen after lock acquired, but handle it) - logger.error( + logger.exception( f"Failed to set DESTINATION_PROCESSING stage after lock acquisition " - f"for file '{file_ctx.file_name}': {str(stage_error)}. " + f"for file '{file_ctx.file_name}'. " f"Releasing lock." ) # Release the lock since we failed to set the stage @@ -658,7 +658,7 @@ class WorkerDestinationConnector: execution_id: str = None, organization_id: str = None, execution_error: str = None, - ) -> HandleOutputResult: + ) -> HandleOutputResult | None: """Handle the output based on the connection type. This refactored version uses clean architecture with context objects