code: def test_pipe_duplex_over_fiber_process(self):
      conn1, conn2 = Pipe(duplex=True)
      p = fiber.Process(target=pipe_worker, args=(conn2,))
      p.start()
      conn1.send(b"hello")
      data = conn1.recv()
      p.join()
      assert data == b"ack"
  
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 7 for calling the TestQueue obj's underlying member method code with example usage: obj.test_pipe_duplex_over_fiber_process() without return types