diff --git a/shared/workspaces/workspaces/workflow/services/workflow_service.py b/shared/workspaces/workspaces/workflow/services/workflow_service.py
index de7e1bbc72f99f07a41f2d932277c78a6ae79a13..d074e8b0e4c12f0376744acac8eb99f9cb3aadb2 100644
--- a/shared/workspaces/workspaces/workflow/services/workflow_service.py
+++ b/shared/workspaces/workspaces/workflow/services/workflow_service.py
@@ -1083,7 +1083,7 @@ class WorkflowMessageHandler:
 
         stage_info = self.info.lookup_workflow_stage(request.workflow_request_id, stage)
 
-        if stage_info and stage_info.end_time is not None:
+        if stage_info and stage_info.end is not None:
             # This entry already exists in progress table, message is a duplicate. Ignore
             return False