Skip to content

Commit

Permalink
Addressed PR comments
Browse files Browse the repository at this point in the history
  • Loading branch information
fernst committed Feb 5, 2025
1 parent 0fc1074 commit d972f35
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 12 deletions.
12 changes: 1 addition & 11 deletions core/actions/data_preparation.ts
Original file line number Diff line number Diff line change
Expand Up @@ -401,18 +401,8 @@ export class DataPreparation extends ActionBuilder<dataform.DataPreparation> {
return dataform.LoadConfiguration.create({"replace": {}});
}

if (typeof loadMode === "number") {
switch (loadMode) {
case dataform.ActionConfig.LoadMode.REPLACE: return dataform.LoadConfiguration.create({"replace": {}});
case dataform.ActionConfig.LoadMode.APPEND: return dataform.LoadConfiguration.create({"append": {}});
case dataform.ActionConfig.LoadMode.MAXIMUM: return dataform.LoadConfiguration.create({"maximum": {"columnName": this.validateLoadModeColumnName(columnName)}});
case dataform.ActionConfig.LoadMode.UNIQUE: return dataform.LoadConfiguration.create({"unique": {"columnName": this.validateLoadModeColumnName(columnName)}});
default: throw new Error(`LoadMode value "${loadMode}" is not supported`);
}
}

switch (loadMode.toString().toUpperCase()) {
case "REPLACE": return dataform.LoadConfiguration.create({"replace": {}});
case "REPLACE_TABLE": return dataform.LoadConfiguration.create({"replace": {}});
case "APPEND": return dataform.LoadConfiguration.create({"append": {}});
case "MAXIMUM": return dataform.LoadConfiguration.create({"maximum": {"columnName": this.validateLoadModeColumnName(columnName)}});
case "UNIQUE": return dataform.LoadConfiguration.create({"unique": {"columnName": this.validateLoadModeColumnName(columnName)}});
Expand Down
2 changes: 1 addition & 1 deletion protos/configs.proto
Original file line number Diff line number Diff line change
Expand Up @@ -558,7 +558,7 @@ message ActionConfig {

enum LoadMode {
// Replace existing table (default).
REPLACE = 0;
REPLACE_TABLE = 0;
// Insert into destination table.
APPEND = 1;
// Insert only records where the specified column value exceeds the existing maximum value in the destination table.
Expand Down

0 comments on commit d972f35

Please sign in to comment.