code: def write_pipe(pipe, msg):
      pipe.send(msg)
  
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 2 for calling a global function with example usage: write_pipe(pipe, msg) without return types