airflow/contrib/task_runner/cgroup_task_runner.py
def _get_cgroup_names():
        """
        :return: a mapping between the subsystem name to the cgroup name
        :rtype: dict[str, str]
        """
        with open("/proc/self/cgroup") as f:
            lines = f.readlines()
            d = {}
            for line in lines:
                line_split = line.rstrip().split(":")
                subsystem = line_split[1]
                group_name = line_split[2]
                d[subsystem] = group_name
            return d
def _get_cgroup_names():
        """
        :return: a mapping between the subsystem name to the cgroup name
        :rtype: dict[str, str]
        """
        with open("/proc/self/cgroup") as f:
            lines = f.readlines()
            d = {}
            for line in lines:
                line_split = line.rstrip().split(":")
                subsystem = line_split[1]
                group_name = line_split[2]
                d[subsystem] = group_name
            return d
def _get_cgroup_names ( ) : with open ( "/proc/self/cgroup" ) as f : lines = f . readlines ( ) d = { } for line in lines : line_split = line . rstrip ( ) . split ( ":" ) subsystem = line_split [ 1 ] group_name = line_split [ 2 ] d [ subsystem ] = group_name return d
:return: a mapping between the subsystem name to the cgroup name
        :rtype: dict[str, str]
: return : a mapping between the subsystem name to the cgroup name : rtype : dict [ str str ]