await savePerformanceByRacerID()

in 2-streaming-kdf/s3-processor/app.js [31:44]


	await savePerformanceByRacerID(jsonRecords)

	// Load history for classes in this batch
	await getHistoryForClasses (jsonRecords)

  // Merge incoming records with histories
	mergeWithHistory (jsonRecords)

  // Save results
	await saveHistoryForClasses (jsonRecords)
}

// Convert incoming data into a JSON array
const convertToJsonArray = (raw) => {