code: def dali_pipe_types(tf_type, dali_type):
      class TestPipeline(pipeline.Pipeline):
          def __init__(self, **kwargs):
              super(TestPipeline, self).__init__(**kwargs)
              self.constant = ops.Constant(
                  dtype=dali_type, idata=[1, 1], shape=[2]
              )
  
          def define_graph(self):
              return self.constant().gpu()
  
      pipe = TestPipeline(batch_size=1, seed=0)
      ds = dali_tf.DALIDataset(
          pipe, batch_size=1, output_dtypes=tf_type
      )
      ds_iter = iter(ds)
      (out,) = ds_iter.next()
      assert_equals(out.dtype, tf_type)
  
imports: import tensorflow
  import nvidia.dali.ops
  import nvidia.dali.pipeline
  import nvidia.dali.plugin.tf
  import nvidia.dali.types
  from test_utils_tensorflow import skip_for_incompatible_tf
  import os
  from nose.tools import assert_equals
  from nose_utils import raises
  import itertools
  import warnings
label_desc: Use image node_id 14 for calling a global function with example usage: dali_pipe_types(tf_type, dali_type) and returns: self