code: def _get_logs(generator, logs, until):
      """Placeholder docstring"""
      now = datetime.now()
      try:
          for next_entry in generator:
              logs.put(
                  next_entry,
                  block=True,
                  timeout=(until - now).total_seconds(),
              )
  
              now = datetime.now()
              if until < now:
                  break
          logger.debug(
              "Container logging done. All container logs processed."
          )
      except (StopIteration, ValueError):
          logger.debug(
              "Container logging stopped. All container logs processed."
          )
  
imports: from __future__ import absolute_import
  import logging
  from threading import Thread
  import queue
  from datetime import datetime
  from sagemaker.serve.utils.exceptions import LocalModelLoadException, LocalModelOutOfMemoryException, LocalModelInvocationException, SkipTuningComboException
label_desc: Use image node_id 1 for calling a global function with example usage: _get_logs(generator, logs, until) without return types