class_docstr: Controls saving and loading of workspaces on every epoch boundary of a job.
  If a CheckpointManager instance is passed to JobRunner, then JobRunner will
  call `init`, `read` and `save` at different moments in between epoch runs.
  
  Args:
      db_prefix: The prefix used to construct full db name. Since `absolute_path`
          is set to True, this will be used as db_name in SaveOp.
      node_name: Name of the node where this checkpoint_manager is used.
      db_type: Type of database to use for storing checkpoint.
      metadata_handler: An optional object capable of reading/writing
          checkpoint info in storage of choice.
class_docstr_tok: ["Controls","saving","and","loading","of","workspaces","on","every","epoch","boundary","of","a","job",".","If","a","CheckpointManager","instance","is","passed","to","JobRunner",",","then","JobRunner","will","call","`","init","`",",","`","read","`","and","`","save","`","at","different","moments","in","between","epoch","runs",".","Args",":","db_prefix",":","The","prefix","used","to","construct","full","db","name",".","Since","`","absolute_path","`","is","set","to","True",",","this","will","be","used","as","db_name","in","SaveOp",".","node_name",":","Name","of","the","node","where","this","checkpoint_manager","is","used",".","db_type",":","Type","of","database","to","use","for","storing","checkpoint",".","metadata_handler",":","An","optional","object","capable","of","reading\/writing","checkpoint","info","in","storage","of","choice","."]
docstr: Builds a Task that loads only the necessary blobs from a checkpoint of
  the given epoch. The necessary blobs are given in the blob_names
  argument.
  
  Args:
      blob_names: A list of strings. Each string is the name of a
          blob.
      epoch: The checkpoint epoch to load from.
  
  Returns:
      A Task which loads the specified blobs from the checkpoint of the
      given epoch.
docstr_tok: ["Builds","a","Task","that","loads","only","the","necessary","blobs","from","a","checkpoint","of","the","given","epoch",".","The","necessary","blobs","are","given","in","the","blob_names","argument",".","Args",":","blob_names",":","A","list","of","strings",".","Each","string","is","the","name","of","a","blob",".","epoch",":","The","checkpoint","epoch","to","load","from",".","Returns",":","A","Task","which","loads","the","specified","blobs","from","the","checkpoint","of","the","given","epoch","."]
code: def load_blobs_from_checkpoint(self, blob_names, epoch):
      """
      Builds a Task that loads only the necessary blobs from a checkpoint of
      the given epoch. The necessary blobs are given in the blob_names
      argument.
  
      Args:
          blob_names: A list of strings. Each string is the name of a
              blob.
          epoch: The checkpoint epoch to load from.
  
      Returns:
          A Task which loads the specified blobs from the checkpoint of the
          given epoch.
      """
      self._current_db_name = db_name(
          epoch, self._node_name, self._db_prefix
      )
      logger.info("Load from %s" % self._current_db_name)
  
      def add_op():
          ops.Load(
              [],
              blob_names,
              db=self._current_db_name,
              db_type=self._db_type,
              absolute_path=True,
              allow_incomplete=True,
          )
  
      return self._timed_task("checkpoint_partial_load", add_op)
  
imports: import os
  import logging
  from caffe2.python import core, context
  from caffe2.python.net_builder import ops
  from caffe2.python.task import final_output, Node, Task, TaskGroup, TaskOutput, WorkspaceType
label_desc: Use image node_id 7 for calling the CheckpointManager obj's underlying member method code with example usage: obj.load_blobs_from_checkpoint(blob_names, epoch) and returns: self