code: def test_udt_datasource1_direct():
      _test_datasource1_udt(datasource1_direct)
  
imports: import pytest
  import numpy
  import pyarrow
  from pyarrow import compute
label_desc: Use image node_id 43 for calling a global function with example usage: test_udt_datasource1_direct() without return types