code: def pipe_mp_worker(writer):
      import multiprocessing as mp
  
      ctx = mp.get_context("spawn")
      p = ctx.Process(
          target=write_pipe, args=(writer, b"hello"), name="WRITE_PIPE"
      )
      p.start()
  
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 a global function with example usage: pipe_mp_worker(writer) without return types