diff --git a/workflows/plugins/event_bus/swipe/event_bus_swipe.py b/workflows/plugins/event_bus/swipe/event_bus_swipe.py index 6ded3774..e1755caf 100644 --- 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":