code: def eval_run_time(pipeline: BasePipeline):
      pipeline.setup(CX())
      a = time.time()
      output = pipeline.transform(list(range(100)))
      b = time.time()
      seconds = b - a
      return seconds, output
  
file_path: Neuraxle/examples/parallel/plot_streaming_pipeline.py
imports: import time
  import numpy
  from neuraxle.base import ExecutionContext
  from neuraxle.distributed.streaming import SequentialQueuedPipeline
  from neuraxle.pipeline import BasePipeline, Pipeline, MiniBatchSequentialPipeline
  from neuraxle.steps.loop import ForEach
  from neuraxle.steps.misc import Sleep
  from neuraxle.steps.numpy import MultiplyByN
label_desc: Use image node_id 1 for calling a global function with example usage: eval_run_time(pipeline) and returns: seconds,  output