code: def _run_device(self, s1, s2):
      rc = nnpy.nanomsg.nn_device(s1.sock, s2.sock)
      return nnpy.errors.convert(rc, rc)
  
imports: import random
  import logging
  import multiprocessing
  import threading
  from fiber.backend import get_backend
label_desc: Use image node_id 4 for calling the NanomsgDevice obj's underlying member method code with example usage: obj._run_device(s1, s2) and returns: nnpy