Como trabalhou com os ficheiros ao reiniciar o DAG após a sua falha, para não sobrescrever os dados no S3 com dados incompletos?