Skip to content

Commit

Permalink
Only process UDs
Browse files Browse the repository at this point in the history
  • Loading branch information
dmgaldi committed May 13, 2024
1 parent c28372f commit 459cce7
Showing 1 changed file with 5 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -35,9 +35,13 @@ public boolean isPerformTableBackup() {

@Override
public TableRowInterfaces.RowResult<AnalysisRow> processRecord(AnalysisRow nextRow) throws Exception {
if (!nextRow.getDatasetId().startsWith("EDAUD")) {
new TableRowInterfaces.RowResult<>(nextRow)
.setShouldWrite(false);
}
String descriptor = nextRow.getDescriptor().toString();
LOG.info("Analysis descriptor before migration: " + descriptor);

// Find all variable IDs.
final Set<String> currentVarIds = VAR_ID_PATTERN.matcher(descriptor).results()
.map(match -> match.group(1))
Expand Down

0 comments on commit 459cce7

Please sign in to comment.