def get_all_local_vars(self):
        """Return the set of all variables in this Assembly and any
        of its children that are local to the current MPI process.
        """
        all_locs = set()
        all_locs.update(self.list_inputs())
        all_locs.update(self.list_outputs())

        for s in [self._system] + list(self._system.local_subsystems(recurse=True)):
            if isinstance(s, SimpleSystem):
                try:
                    obj = self.get(s.name)
                except:
                    continue
                if has_interface(obj, IAssembly):
                    all_locs.update(['.'.join([obj.name, n])
                                          for n in obj.get_all_local_vars()])
                elif has_interface(obj, IComponent):
                    lvars = ['.'.join([obj.name, n])
                                          for n in obj.list_inputs() +
                                                   obj.list_outputs()]
                    for i, v in enumerate(lvars):
                        if s.distrib_idxs in v:
                            lvars[i] = (v,)  # wrap in tuple to indicate its a distrib var
                    all_locs.update(lvars)

                elif isinstance(s, ParamSystem):
                    all_locs.add(s.name)

        return all_locs
dataset/ETHPy150Open OpenMDAO/OpenMDAO-Framework/openmdao.main/src/openmdao/main/assembly.py/Assembly.get_all_local_vars/swapped operands of `in`