9b7b23fd9bbc8baad2d2f88c1a66a2547683cd40,examples/dataflow-data-generator/data-generator-pipeline/data_generator/AvroUtil.py,,fix_record_for_avro,#Any#Any#,21

Before Change

def fix_record_for_avro(record, avro_schema):
    for field in avro_schema.fields:
        field_name = field.name
        datatype = field.type.to_json()
        if isinstance(datatype, dict):
            // This is a record type definition so we need to recurse a level deeper.
            record[field_name] = fix_record_for_avro(
                record[field_name], avro.schema.Parse(json.dumps(datatype)))[0]

After Change

def fix_record_for_avro(record, avro_schema):
    for field in avro_schema["fields"]:
        field_name = field["name"]
        datatype = field["type"]
        if isinstance(datatype, dict):

Instances