From 2f9f12859308adb13984cb239875fa03dfc4f92c Mon Sep 17 00:00:00 2001 From: Greg Leclercq Date: Tue, 5 Aug 2014 22:10:39 +0200 Subject: [PATCH] Update history #6: support schedule_failed events --- simpleflow/history.py | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/simpleflow/history.py b/simpleflow/history.py index 28c58205e..5f87e2707 100644 --- a/simpleflow/history.py +++ b/simpleflow/history.py @@ -34,6 +34,11 @@ def get_activity(event): # in ``retry``. As the state of the event mutates, it # corresponds to the last execution. self._activities[event.activity_id].update(activity) + elif event.state == 'schedule_failed': + activity = self._activities[event.activity_id] + activity['state'] = event.state + activity['cause'] = event.cause + activity['activity_type'] = event.activity_type.copy() elif event.state == 'started': activity = get_activity(event) activity['state'] = event.state