code: def datasource1_direct():
      """A short dataset"""
      schema = datasource1_schema()
  
      class Generator:
          def __init__(self):
              self.n = 3
  
          def __call__(self, ctx):
              if self.n == 0:
                  batch = _record_batch_from_iters(schema, [], [])
              else:
                  self.n -= 1
                  batch = _record_batch_for_range(schema, self.n)
              return batch.to_struct_array()
  
      return lambda ctx: Generator()
  
imports: import pytest
  import numpy
  import pyarrow
  from pyarrow import compute
label_desc: Use image node_id 37 for calling a global function with example usage: datasource1_direct() and returns: function, batch