def finalize_pipeline(self, pipeline, to_delete, objs, errs, execs,
                          suspended, cached, **kwargs):
        def fetch(name, default):
            return kwargs.pop(name, default)
        reset_computed = fetch('reset_computed', True)
        view = fetch('view', None)

        self.clean_modules(to_delete)

        if view is not None:
            for i in objs:
                if errs in i:
                    view.set_module_error(i, errs[i].msg, errs[i].errorTrace)
                elif i in suspended and suspended[i]:
                    view.set_module_suspended(i, suspended[i])
                elif i in execs and execs[i]:
                    view.set_module_success(i)
                elif i in cached and cached[i]:
                    view.set_module_not_executed(i)
                else:
                    view.set_module_persistent(i)

        if reset_computed:
            for module in self._objects.itervalues():
                module.computed = False
dataset/ETHPy150Open VisTrails/VisTrails/vistrails/core/interpreter/cached.py/CachedInterpreter.finalize_pipeline/swapped operands of `in`