code: def get_queue(q_in, q_out, n):
      print("get_queue started", q_in, q_in.reader, q_in.writer)
      for i in range(n):
          d = q_in.get()
          q_out.put(d)
      time.sleep(1)
      print("get_queue finished")
  
imports: import fiber
  import pickle
  import time
  import pytest
  import docker
  import collections
  import multiprocessing
  from fiber.queues import Pipe, SimpleQueue
  from fiber.socket import Socket
label_desc: Use image node_id 4 for calling a global function with example usage: get_queue(q_in, q_out, n) without return types