code: def testForEach_Subpipeline_NotImplemented(self):
      a = A()
      with self.assertRaises(NotImplementedError):
          with for_each.ForEach(a.outputs["aa"]) as aa:
              p_in = pipeline_lib.PipelineInputs({"aa": aa})
              b = B(aa=p_in.inputs["aa"])
              pipeline_lib.Pipeline(
                  pipeline_name="foo",
                  components=b,
                  inputs=p_in,
                  outputs={},
              )
  
imports: import unittest
  import tensorflow
  from tfx import types
  from tfx.dsl.components.base import base_node
  from tfx.dsl.context_managers import dsl_context_registry
  from tfx.dsl.control_flow import for_each
  from tfx.orchestration import pipeline
  from tfx.types import resolved_channel
  from tfx.utils import test_case_utils
label_desc: Use image node_id 7 for calling the ForEachTest obj's underlying member method code with example usage: obj.testForEach_Subpipeline_NotImplemented() without return types