Closes #2386

idaholab · Oct 21, 2024 · d2f4ec3 · d2f4ec3
1 parent 515c65a
commit d2f4ec3
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 0 deletions.
diff --git a/ravenframework/Models/Code.py b/ravenframework/Models/Code.py
@@ -529,6 +529,7 @@ def evaluateSample(self, myInput, samplerType, kwargs):
     sampleDirectory = os.path.join(os.getcwd(),metaData['subDirectory'])
     localenv = dict(os.environ)
     localenv['PWD'] = str(sampleDirectory)
+    os.makedirs(os.path.dirname(os.path.join(sampleDirectory,codeLogFile)), exist_ok=True)
     outFileObject = open(os.path.join(sampleDirectory,codeLogFile), 'w', bufferSize)
 
     found = False

diff --git a/ravenframework/Steps/MultiRun.py b/ravenframework/Steps/MultiRun.py
@@ -267,6 +267,12 @@ def _localTakeAstepRun(self, inDictionary):
     # END while loop that runs the step iterations (collection and submission-for-DET)
     # if any collected runs failed, let the sampler treat them appropriately, and any other closing-out actions
     sampler.finalizeSampler(self.failedRuns)
+    for myLambda, outIndex in self._outputCollectionLambda:
+      if isinstance(outputs[outIndex], OutStreamEntity):
+        myLambda([None,outputs[outIndex]])
+        self.raiseAMessage(f'Just collected job {finishedJob.identifier} and sent to output "{inDictionary["Output"][outIndex].name}"')
+
+
 
   def _addNewRuns(self, sampler, model, inputs, outputs, jobHandler, inDictionary, verbose=True):
     """