Adding more logs.

clients/bigquery/merge.go

@@ -3,6 +3,7 @@ package bigquery
 import (
 	"context"
 	"fmt"
+	"log/slog"
 	"strings"
 
 	"github.com/artie-labs/transfer/clients/shared"
@@ -31,6 +32,7 @@ func (s *Store) Merge(ctx context.Context, tableData *optimization.TableData) er
 		additionalEqualityStrings = []string{mergeString}
 	}
 
+	slog.Info("### Starting to merge", s.config.SharedDestinationSettings.ColumnSettings.BigQueryNumericForVariableNumeric)
 	return shared.Merge(ctx, s, tableData, types.MergeOpts{
 		AdditionalEqualityStrings: additionalEqualityStrings,
 		ColumnSettings:            s.config.SharedDestinationSettings.ColumnSettings,

clients/shared/table.go

@@ -26,7 +26,7 @@ func CreateTable(ctx context.Context, dwh destination.DataWarehouse, tableData *
 		return fmt.Errorf("failed to build create table sql: %w", err)
 	}
 
-	slog.Info("[DDL] Executing query", slog.String("query", query))
+	slog.Info("[DDL] Executing query", slog.String("query", query), slog.Bool("numeric setting", settings.BigQueryNumericForVariableNumeric))
 	if _, err = dwh.ExecContext(ctx, query); err != nil {
 		return fmt.Errorf("failed to create temp table: %w", err)
 	}

lib/destination/ddl/ddl.go

@@ -34,6 +34,7 @@ func BuildCreateTableSQL(settings config.SharedDestinationColumnSettings, dialec
 			primaryKeys = append(primaryKeys, colName)
 		}
 
+		slog.Info("settings", settings.BigQueryNumericForVariableNumeric)
 		parts = append(parts, fmt.Sprintf("%s %s", colName, dialect.DataTypeForKind(col.KindDetails, col.PrimaryKey(), settings)))
 	}