Essa função está faltando terminar. O try não tem o fechamento e quebra quando roda o lambda function
def register_glue_partitions(output_name: str, partitions: set[tuple[int, int]]) -> None:
try:
if not partitions:
return
location_base = f"s3://{S3_BUCKET}/silver/{output_name}"
partition_inputs = []
for year, month in partitions:
partition_inputs.append(
{
"Values": [str(year), str(month)],
"StorageDescriptor": {
"Location": f"{location_base}/year={year}/month={month:02d}/",
"InputFormat": "org.apache.hadoop.hive.ql.io.parquet.MapredParquetInputFormat",
"OutputFormat": "org.apache.hadoop.hive.ql.io.parquet.MapredParquetOutputFormat",
"SerdeInfo": {
"SerializationLibrary": "org.apache.hadoop.hive.ql.io.parquet.serde.ParquetHiveSerDe",
},
},
}
)
