'Iterate over all subtasks that are currently running.
Running subtasks are subtasks have been started but have not yet
completed.'

def _running(self):

    def running(k_r):
        return ((k_r[0] in self._graph) and k_r[1].started())
    return six.moves.filter(running, six.iteritems(self._runners))
