Skip to content

Commit 6f6dd97

Browse files
committed
🚑 fix transformations execution order
1 parent 94f7211 commit 6f6dd97

1 file changed

Lines changed: 7 additions & 3 deletions

File tree

  • src/command-handlers

src/command-handlers/up.js

Lines changed: 7 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ const executeDataTransformation = async (ddb, transformation, table, isDryRun) =
3131
}
3232
};
3333

34-
const isGreaterThanLatesttransformationNumber = (fileName, latestDataTransformationNumber) => {
34+
const isGreaterThanLatestTransformationNumber = (fileName, latestDataTransformationNumber) => {
3535
const transformationFileNumber = parseTransformationFileNumber(fileName);
3636
return transformationFileNumber > latestDataTransformationNumber;
3737
};
@@ -42,10 +42,14 @@ const getScriptsToExecuteForTable = async (table, latestDataTransformationNumber
4242

4343
const currentTransformationFiles = transformationFiles.filter((fileName) => {
4444
const isJsFile = path.extname(fileName) === TRANSFORMATION_SCRIPT_EXTENSION;
45-
return isJsFile && isGreaterThanLatesttransformationNumber(fileName, latestDataTransformationNumber);
45+
return isJsFile && isGreaterThanLatestTransformationNumber(fileName, latestDataTransformationNumber);
4646
});
4747

48-
const sortedTransformationFiles = currentTransformationFiles.sort();
48+
const sortedTransformationFiles = currentTransformationFiles.sort((a, b) => {
49+
const aNumber = parseTransformationFileNumber(a);
50+
const bNumber = parseTransformationFileNumber(b);
51+
return aNumber - bNumber;
52+
});
4953

5054
const scriptsToExecute = sortedTransformationFiles
5155
.map((fileName) => require(

0 commit comments

Comments
 (0)