code: def recv_message_tensors(self, message: PipeMessage) -> PipeMessage:
      # Tensors already contained within message
      message.tensors = to_input_device(
          message.tensors, self.input_device
      )
      return message
  
imports: from abc import ABC
  from dataclasses import dataclass
  from queue import Empty
  from queue import Queue
  from typing import Dict, List, Optional
  import torch
  from fairscale.internal.object import pyobject_to_tensor, tensor_to_pyobject
  from fairscale.nn.model_parallel import get_pipeline_parallel_group
  from .types import MESSAGE_GENERATION_START, InputDevice, PipeMessage, Tensors
label_desc: Use image node_id 3 for calling the RpcTransport obj's underlying member method code with example usage: obj.recv_message_tensors(message) and returns: message