message status breaking

chanzuckerberg · Mar 29, 2024 · 175b924 · 175b924
1 parent f26789c
commit 175b924
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/workflows/plugins/event_bus/swipe/event_bus_swipe.py b/workflows/plugins/event_bus/swipe/event_bus_swipe.py
@@ -67,6 +67,9 @@ def _parse_message(self, message: dict) -> WorkflowStatusMessage | None:
         # TODO: handle aws.batch for step statuses
         if not message.get("source") == "aws.states":
             return None
+        if not message.get("status"):
+            print("No status in message: ", message)
+            return None
         status = self._create_workflow_status(message["status"])
         execution_arn = message["detail"]["executionArn"]
         if status == "WORKFLOW_SUCCESS":