code: def test_callable_combinefn_in_beam(self):
      sum_fn = _SumCombineFn()
      with beam.Pipeline() as pipeline:
          result = (
              pipeline
              | beam.Create([1, 2, 3])
              | beam.CombineGlobally(sum_fn)
          )
          util.assert_that(result, util.equal_to([6]))
  
file_path: model-analysis/tensorflow_model_analysis/experimental/lazytf/core_test.py
imports: from absl.testing import absltest
  import apache_beam
  from apache_beam.testing import util
  from tensorflow_model_analysis.experimental.lazytf import core
label_desc: Use image node_id 2 for calling the CoreTest obj's underlying member method code with example usage: obj.test_callable_combinefn_in_beam() without return types