def METHOD_NAME(self):
    @dsl.pipeline()
    def my_pipeline(meta_inp1: str, meta_inp2: int):
        dataset = importer_node.importer(
            'gs://my_bucket',
            Dataset,
            reimport=True,
            metadata={
                'outer_key': [meta_inp1, meta_inp2],
                meta_inp1: meta_inp1
            })
    pipeline_spec = my_pipeline.pipeline_spec
    input_keys = list(pipeline_spec.components['comp-importer']
                      .input_definitions.parameters.keys())
    self.assertIn('metadata', input_keys)
    deployment_spec = pipeline_spec.deployment_spec.fields[
        'executors'].struct_value.fields['exec-importer']
    metadata = deployment_spec.struct_value.fields[
        'importer'].struct_value.fields['metadata']
    self.assertEqual(
        metadata.struct_value.fields['outer_key'].list_value.values[0]
        .string_value, "{{$.inputs.parameters['metadata']}}")
    self.assertEqual(
        metadata.struct_value.fields['outer_key'].list_value.values[1]
        .string_value, "{{$.inputs.parameters['metadata-2']}}")
    self.assertEqual(
        metadata.struct_value.fields["{{$.inputs.parameters['metadata']}}"]
        .string_value, "{{$.inputs.parameters['metadata']}}")