loaded = spark.read.format("avro").load(str(output_path))