'Make sure all fluentd pods are running. Returns: error string'

def check_fluentd_pods_running(self, pods):

    not_running = super(Fluentd, self).not_running_pods(pods)
    if not_running:
        return [OpenShiftCheckException('FluentdNotRunning', 'The    following    Fluentd    pods    are    supposed    to    be    running    but    are    not:\n        {pods}\nThese    pods    will    not    aggregate    logs    from    their    nodes.'.format(pods='\n'.join(('        {name}    ({host})'.format(name=pod['metadata']['name'], host=pod['spec'].get('host', 'None')) for pod in not_running))))]
    return []
