diff --git a/nipype/pipeline/engine/nodes.py b/nipype/pipeline/engine/nodes.py
index af93fd140b..53056f990e 100644
--- a/nipype/pipeline/engine/nodes.py
+++ b/nipype/pipeline/engine/nodes.py
@@ -565,8 +565,10 @@ def _load_results(self):
                 self.inputs.trait_set(**old_inputs)
             if not isinstance(self, MapNode):
                 self._copyfiles_to_wd(linksonly=True)
-                aggouts = self._interface.aggregate_outputs(
-                    needed_outputs=self.needed_outputs)
+                with indirectory(cwd):
+                    aggouts = self._interface.aggregate_outputs(
+                        needed_outputs=self.needed_outputs)
+                        
                 runtime = Bunch(
                     cwd=cwd,
                     returncode=0,