code: def test_data_pipeline(gen_func):
      import time
  
      tmp = time.time()
      for idx, data in enumerate(gen_func()):
          print(time.time() - tmp)
          tmp = time.time()
          if idx == 100:
              break
  
imports: import argparse
  import time
  import os
  import math
  from multiprocessing import Process
  import numpy
  import paddle.fluid
  import paddle.fluid.layers
  from paddle.fluid.incubate.fleet.parameter_server.distribute_transpiler import fleet
  from paddle.fluid.incubate.fleet.parameter_server.distribute_transpiler import StrategyFactory
  import paddle.fluid.incubate.fleet.base.role_maker
  import pgl
  from pgl.utils.logger import log
  from pgl import data_loader
  from reader import DeepwalkReader
  from model import DeepwalkModel
  from utils import get_file_list
  from utils import build_graph
  from utils import build_random_graph
  from utils import build_fake_graph
  from utils import build_gen_func
label_desc: Use image node_id 6 for calling a global function with example usage: test_data_pipeline(gen_func) without return types