code: def define_graph(self):
      self.jpegs, self.labels = self.input(name="Reader")
      images = self.decode(self.jpegs)
      if self.warp.device == "gpu":
          images = images.gpu()
      if self.cast:
          images = self.cast(images)
  
      dynamic_size = (
          types.Constant(np.array([240, 320], dtype=np.float32))
          if self.use_dynamic_size
          else None
      )
  
      if self.use_input:
          transform = self.transform_source()
          outputs = self.warp(images, transform, size=dynamic_size)
      else:
          outputs = self.warp(images, size=dynamic_size)
      return outputs
  
imports: import nose_utils
  from nvidia.dali.pipeline import Pipeline
  import nvidia.dali.ops
  import nvidia.dali.fn
  import nvidia.dali.types
  import numpy
  import math
  import os
  import cv2
  from sequences_test_utils import video_suite_helper, SampleDesc, ArgCb
  from test_utils import compare_pipelines
  import random
label_desc: Use image node_id 2 for calling the WarpPipeline obj's underlying member method code with example usage: obj.define_graph() and returns: outputs