def get_pending_activities()

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
  ]