code: def datasource1_exception():
      schema = datasource1_schema()
  
      def batch_gen(ctx):
          for n in range(3, 0, -1):
              # ctx =
              yield _record_batch_for_range(schema, n - 1)
          raise RuntimeError("datasource1_exception")
  
      return make_udt_func(schema, batch_gen)
  
imports: import pytest
  import numpy
  import pyarrow
  from pyarrow import compute
label_desc: Use image node_id 39 for calling a global function with example usage: datasource1_exception() and returns: make_udt_func