in aws/hhvm1/lambdas/health_check.py [0:0]
def get_pending_activities(events):
started_event_ids = {
e['previousEventId'] for e in events if e['type'] == 'ActivityStarted'
}
pending_arns = {
e['activityScheduledEventDetails']['resource'] for e in events
if e['type'] == 'ActivityScheduled' and not e['id'] in started_event_ids
}
if not pending_arns:
return []
return [
a for a in Activity.__subclasses__() if a.activity_arn in pending_arns
]