@beam.ptransform_fn
@beam.typehints.with_input_types(bytes)
@beam.typehints.with_output_types(types.Extracts)
def InputsToExtracts(inputs: beam.pvalue.PCollection):
    'Converts serialized inputs (e.g. examples) to Extracts.'
    return (inputs | beam.Map((lambda x: {constants.INPUT_KEY: x})))
Converts serialized inputs (e.g. examples) to Extracts.
@beam.ptransform_fn
@beam.typehints.with_input_types(bytes)
@beam.typehints.with_output_types(types.Extracts)
def InputsToExtracts(inputs: beam.pvalue.PCollection):
    
    return (inputs | beam.Map((lambda x: {constants.INPUT_KEY: x})))