code: def double_queue_worker(args):
      i, (instructions, returns) = args
      print("[worker]LOOPING", i)
      # instructions, returns = SUBPROC_QUEUES[i]
      assert instructions is not None
      assert returns is not None
      returns.put("READY {}".format(i))
      print("[worker]PUT READY", i)
  
      while True:
          # quit after got one instruction. This makes sure each worker gets at
          # least one instruction.
          ins = instructions.get()
          print("[worker]GOT", ins, i)
          if ins == "QUIT":
              # print('[worker]got QUIT exiting', i)
              break
  
          returns.put("ACK {}".format(i))
          print("[worker]PUT ACK", i)
  
imports: import os
  import time
  from fiber import Pool, SimpleQueue
  import fiber
  import pytest
  import docker
  import threading
  import random
  import fiber.config
label_desc: Use image node_id 6 for calling a global function with example usage: double_queue_worker(args) without return types