in bigquery/main.go [114:125]
func (bqf *actualBQFactory) Make(ctx context.Context) (bq, error) {
projectID := os.Getenv("PROJECT_ID")
if projectID == "" {
return nil, errors.New("PROJECT_ID environment variable must be set")
}
bqClient, err := bigquery.NewClient(ctx, projectID)
if err != nil {
return nil, fmt.Errorf("error initializing bigquery client: %v", err)
}
newClient := &actualBQ{client: bqClient}
return newClient, nil
}