code: def wait_for_next_completion(self, runtime_context):
          # type: (RuntimeContext) -> None
          
          if runtime_context.workflow_eval_lock is not None:
              runtime_context.workflow_eval_lock.wait()
          if self.exceptions:
              raise self.exceptions[0]
docs: Wait for jobs to finish.