func initialize()

in workload-management/s3-trigger-ecs-task/s3-file-processor/main.go [111:139]


func initialize() (*os.File, *os.File, error) {
	// Get input file
	inputFilePath, err := utils.CopyS3ToTmp()
	if err != nil {
		return nil, nil, err
	}

	inputFile, err := utils.GetFile(*inputFilePath)
	if err != nil {
		log.Printf("Error while getting the input file " + err.Error())
		return nil, nil, err
	}

	// Delete and recreate output file
	outputFile, err := utils.TruncateFile(utils.GetOutputFile(true))
	if err != nil {
		log.Printf("Error while creating output file " + err.Error())
		return nil, nil, err
	}

	// Delete and recreate table
	err = utils.RecreateTable()
	if err != nil {
		log.Printf("Error while creating dynamodb tables " + err.Error())
		return nil, nil, err
	}

	return inputFile, outputFile, nil
}