Skip to content

Commit

Permalink
Add method
Browse files Browse the repository at this point in the history
  • Loading branch information
nathan-artie committed May 13, 2024
1 parent 587a5a7 commit fe8c166
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 1 deletion.
2 changes: 1 addition & 1 deletion clients/shared/append.go
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,7 @@ func Append(dwh destination.DataWarehouse, tableData *optimization.TableData, op
return fmt.Errorf("failed to get table config: %w", err)
}

tableData.ReadOnlyInMemoryCols().DeleteColumn(constants.DeleteColumnMarker)
tableData.InMemoryColumns().DeleteColumn(constants.DeleteColumnMarker)

// We don't care about srcKeysMissing because we don't drop columns when we append.
_, targetKeysMissing := columns.Diff(
Expand Down
4 changes: 4 additions & 0 deletions lib/optimization/table_data.go
Original file line number Diff line number Diff line change
Expand Up @@ -74,6 +74,10 @@ func (t *TableData) Name() string {
return t.name
}

func (t *TableData) InMemoryColumns() *columns.Columns {
return t.inMemoryColumns
}

func (t *TableData) SetInMemoryColumns(columns *columns.Columns) {
t.inMemoryColumns = columns
}
Expand Down

0 comments on commit fe8c166

Please sign in to comment.