dfc8af582ce6f25e6b9f5d338b22bff1c41538d7,framework/Steps.py,MultiRun,_addNewRuns,#MultiRun#Any#Any#Any#Any#Any#Any#,739

Before Change

    //// in addition, we cannot provide more jobs than the sampler can provide.
    //// So, we take the minimum of these two values.
    self.raiseADebug("Testing if the sampler is ready to generate a new input")
    for _ in range(min(jobHandler.availability(isEnsemble), sampler.endJobRunnable())):
      if sampler.amIreadyToProvideAnInput():
        try:
          newInput = self._findANewInputToRun(sampler, model, inputs, outputs, jobHandler)
          if newInput is not None:
            model.submit(newInput, inDictionary[self.samplerType].type, jobHandler, **copy.deepcopy(sampler.inputInfo))
        except utils.NoMoreSamplesNeeded:
          self.raiseAMessage(" ... Sampler returned "NoMoreSamplesNeeded".  Continuing...")
          break
      else:
        self.raiseADebug(" ... sampler has no new inputs currently.")
        break

  def _findANewInputToRun(self, sampler, model, inputs, outputs, jobHandler):
    
      Repeatedly calls Sampler until a new run is found or "NoMoreSamplesNeeded" is raised.
      @ In, sampler, Sampler, the sampler in charge of generating the sample

After Change

    //// in addition, we cannot provide more jobs than the sampler can provide.
    //// So, we take the minimum of these two values.
    self.raiseADebug("Testing if the sampler is ready to generate a new input")
    for _ in range(min(jobHandler.availability(isEnsemble), sampler.endJobRunnable())):
      if sampler.amIreadyToProvideAnInput():
        try:
          newInput = self._findANewInputToRun(sampler, model, inputs, outputs, jobHandler)
          if newInput is not None:
            model.submit(newInput, inDictionary[self.samplerType].type, jobHandler, **copy.deepcopy(sampler.inputInfo))
        except utils.NoMoreSamplesNeeded:
          self.raiseAMessage(" ... Sampler returned "NoMoreSamplesNeeded".  Continuing...")
          break
      else:
        self.raiseADebug(" ... sampler has no new inputs currently.")
        break
    else:
      self.raiseADebug(" ... no available JobHandler spots currently (or the Sampler is done.)")

  def _findANewInputToRun(self, sampler, model, inputs, outputs, jobHandler):
    
      Repeatedly calls Sampler until a new run is found or "NoMoreSamplesNeeded" is raised.
      @ In, sampler, Sampler, the sampler in charge of generating the sample

Instances