Update history #6: support schedule_failed events

botify-labs · Aug 5, 2014 · 2f9f128 · 2f9f128
1 parent cbfdaf6
commit 2f9f128
Showing 1 changed file with 5 additions and 0 deletions.
diff --git 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