Redo

artie-labs · May 13, 2024 · 456849b · 456849b
1 parent dc7d081
commit 456849b
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/clients/shared/append.go b/clients/shared/append.go
@@ -21,11 +21,11 @@ func Append(dwh destination.DataWarehouse, tableData *optimization.TableData, op
 		return fmt.Errorf("failed to get table config: %w", err)
 	}
 
-	srcColumns, _ := columns.RemoveDeleteColumnMarker(tableData.ReadOnlyInMemoryCols().GetColumns())
+	tableData.ReadOnlyInMemoryCols().DeleteColumn(constants.DeleteColumnMarker)
 
 	// We don't care about srcKeysMissing because we don't drop columns when we append.
 	_, targetKeysMissing := columns.Diff(
-		srcColumns,
+		tableData.ReadOnlyInMemoryCols().GetColumns(),
 		tableConfig.Columns().GetColumns(),
 		false,
 		tableData.TopicConfig().IncludeArtieUpdatedAt,