chore: add columns in one go instead of adding it single

rudderlabs · Dec 9, 2024 · 56219a5 · 56219a5
1 parent 446666b
commit 56219a5
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/router/batchrouter/asyncdestinationmanager/snowpipestreaming/channel.go b/router/batchrouter/asyncdestinationmanager/snowpipestreaming/channel.go
@@ -65,10 +65,8 @@ func (m *Manager) addColumns(ctx context.Context, namespace, tableName string, c
 	defer func() {
 		snowflakeManager.Cleanup(ctx)
 	}()
-	for _, column := range columns {
-		if err = snowflakeManager.AddColumns(ctx, tableName, []whutils.ColumnInfo{column}); err != nil {
-			return fmt.Errorf("adding column: %w", err)
-		}
+	if err = snowflakeManager.AddColumns(ctx, tableName, columns); err != nil {
+		return fmt.Errorf("adding column: %w", err)
 	}
 	return nil
 }