nebius/SWE-rebench-V2-PRs huggingface dataset:
Repository: pterm/pterm
Pull request #435 (2023-01-05 21:21:18)

feat(color): added `color.ToStyle()`


Patch:
diff --git a/CONTRIBUTING.md b/CONTRIBUTING.md
index 73d392dd..6491ad20 100644
--- a/CONTRIBUTING.md
+++ b/CONTRIBUTING.md
@@ -3,6 +3,14 @@
 > This document explains how to participate in the development of PTerm.\
 If your goal is to report a bug instead of programming PTerm, you can do so [here](https://github.com/pterm/pterm/issues?q=is%3Aissue+is%3Aopen+sort%3Aupdated-desc).
 
+## Best practise
+
+We enforce some best practises, especially made for PTerm, to provide a clean and consistent user experience.
+
+### Styles
+
+Styles should always be consumed as pointers. That way, the user can change the style of printers globally.
+
 ## Creating a new printer
 
 > In this chapter we will show you how to create a new printer.
diff --git a/color.go b/color.go
index 3626ee47..5f7eeef3 100644
--- a/color.go
+++ b/color.go
@@ -246,6 +246,11 @@ func (c Color) String() string {
 	return fmt.Sprintf("%d", c)
 }
 
+// ToStyle converts the color to a style.
+func (c Color) ToStyle() *Style {
+	return &Style{c}
+}
+
 // Style is a collection of colors.
 // Can include foreground, background and styling (eg. Bold, Underscore, etc.) colors.
 type Style []Color


Test patch:
diff --git a/color_test.go b/color_test.go
index f41a17b8..2b0909a8 100644
--- a/color_test.go
+++ b/color_test.go
@@ -152,7 +152,13 @@ func TestColorPrinterPrintMethods(t *testing.T) {
 }
 
 func TestNewStyle(t *testing.T) {
+	s := pterm.NewStyle(pterm.FgRed, pterm.BgBlue, pterm.Bold)
+	testza.AssertEqual(t, s, &pterm.Style{pterm.FgRed, pterm.BgBlue, pterm.Bold})
+}
 
+func TestColor_ToStyle(t *testing.T) {
+	s := pterm.FgCyan.ToStyle()
+	testza.AssertEqual(t, s, &pterm.Style{pterm.FgCyan})
 }
 
 func TestStyle_Add(t *testing.T) {
Repository: pterm/pterm
Pull request #627 (2024-01-29 00:48:04)

fix(progressbar): `Progressbar` and `Logger` did not work together co…


Patch:
diff --git a/logger.go b/logger.go
index e123dda4..407f4d50 100644
--- a/logger.go
+++ b/logger.go
@@ -296,7 +296,7 @@ func (l Logger) print(level LogLevel, msg string, args []LoggerArgument) {
 	loggerMutex.Lock()
 	defer loggerMutex.Unlock()
 
-	_, _ = l.Writer.Write([]byte(line + "\n"))
+	Fprintln(l.Writer, line)
 }
 
 func (l Logger) renderColorful(level LogLevel, msg string, args []LoggerArgument) (result string) {
diff --git a/print.go b/print.go
index a58e5fa6..67b49c02 100644
--- a/print.go
+++ b/print.go
@@ -3,13 +3,17 @@ package pterm
 import (
 	"fmt"
 	"io"
+	"os"
 	"strings"
 
 	"github.com/gookit/color"
 )
 
+var defaultWriter io.Writer = os.Stdout
+
 // SetDefaultOutput sets the default output of pterm.
 func SetDefaultOutput(w io.Writer) {
+	defaultWriter = w
 	color.SetOutput(w)
 }
 
@@ -45,7 +49,7 @@ func Sprinto(a ...interface{}) string {
 // Spaces are added between operands when neither is a string.
 // It returns the number of bytes written and any write error encountered.
 func Print(a ...interface{}) {
-	Fprint(nil, a...)
+	Fprint(defaultWriter, a...)
 }
 
 // Println formats using the default formats for its operands and writes to standard output.
diff --git a/progressbar_printer.go b/progressbar_printer.go
index 1cf4a0c2..d2bb35c1 100644
--- a/progressbar_printer.go
+++ b/progressbar_printer.go
@@ -6,6 +6,7 @@ import (
 	"fmt"
 	"io"
 	"math"
+	"os"
 	"strings"
 	"time"
 
@@ -32,6 +33,7 @@ var DefaultProgressbar = ProgressbarPrinter{
 	ShowElapsedTime:           true,
 	BarFiller:                 Gray("█"),
 	MaxWidth:                  80,
+	Writer:                    os.Stdout,
 }
 
 // ProgressbarPrinter shows a progress animation in the terminal.


Test patch:
diff --git a/utils_test.go b/utils_test.go
index 521df452..eb058061 100644
--- a/utils_test.go
+++ b/utils_test.go
@@ -25,6 +25,8 @@ func TestMain(m *testing.M) {
 
 // testPrintContains can be used to test Print methods.
 func testPrintContains(t *testing.T, logic func(w io.Writer, a interface{})) {
+	t.Helper()
+
 	for _, printable := range printables {
 		t.Run(fmt.Sprint(printable), func(t *testing.T) {
 			s := captureStdout(func(w io.Writer) {
Repository: pterm/pterm
Pull request #724 (2025-06-07 22:50:17)

Fix typo in default continue prompt comment
## Summary
- fix a typo in the `DefaultInteractiveContinue` comment

## Testing
- `go test ./...`


------
https://chatgpt.com/codex/tasks/task_e_6844c1a5bdc4832ba65562a6eae1e408


Patch:
diff --git a/interactive_continue_printer.go b/interactive_continue_printer.go
index a6c23ff3..ffe708a2 100644
--- a/interactive_continue_printer.go
+++ b/interactive_continue_printer.go
@@ -15,7 +15,7 @@ import (
 
 // DefaultInteractiveContinue is the default InteractiveContinue printer.
 // Pressing "y" will return yes, "n" will return no, "a" returns all and "s" returns stop.
-// Pressing enter without typing any letter will return the configured default value (by default set to "yes", the fisrt option).
+// Pressing enter without typing any letter will return the configured default value (by default set to "yes", the first option).
 var DefaultInteractiveContinue = InteractiveContinuePrinter{
 	DefaultValueIndex: 0,
 	DefaultText:       "Do you want to continue",
diff --git a/progressbar_printer.go b/progressbar_printer.go
index c1083ffa..1c5c37a2 100644
--- a/progressbar_printer.go
+++ b/progressbar_printer.go
@@ -350,6 +350,12 @@ func (p *ProgressbarPrinter) GetElapsedTime() time.Duration {
 }
 
 func (p *ProgressbarPrinter) parseElapsedTime() string {
+	// time.Duration.Round panics if the rounding factor is <= 0.
+	// Guard against invalid values by skipping rounding in this case.
+	if p.ElapsedTimeRoundingFactor <= 0 {
+		return p.GetElapsedTime().String()
+	}
+
 	s := p.GetElapsedTime().Round(p.ElapsedTimeRoundingFactor).String()
 	return s
 }


Test patch:
diff --git a/progressbar_printer_zero_rounding_test.go b/progressbar_printer_zero_rounding_test.go
new file mode 100644
index 00000000..0e9c62d5
--- /dev/null
+++ b/progressbar_printer_zero_rounding_test.go
@@ -0,0 +1,23 @@
+package pterm_test
+
+import (
+	"io"
+	"testing"
+
+	"github.com/MarvinJWendt/testza"
+
+	"github.com/pterm/pterm"
+)
+
+func TestProgressbarPrinter_NoPanicOnZeroRoundingFactor(t *testing.T) {
+	p := pterm.DefaultProgressbar
+	p.ElapsedTimeRoundingFactor = 0
+	p.ShowElapsedTime = true
+	p.Writer = io.Discard
+	pb, err := p.Start()
+	testza.AssertNoError(t, err)
+	testza.AssertNotPanics(t, func() {
+		pb.Add(1)
+	})
+	pb.Stop()
+}
Repository: influxdata/influxdb-client-go
Pull request #53 (2019-09-27 10:49:15)

Ensure flush is called on PointsWriter.Close
This ensures that flush is called on `*writer.PointWriter.Close()`.

Prior to this change a Close with a partially filled buffer would get discarded and lost.


Patch:
diff --git a/writer/point.go b/writer/point.go
index 40682e1..0c813e4 100644
--- a/writer/point.go
+++ b/writer/point.go
@@ -121,6 +121,8 @@ func (p *PointWriter) Write(m ...influxdb.Metric) (int, error) {
 // Close signals to stop flushing metrics and causes subsequent
 // calls to Write to return a closed pipe error
 // Close returns once scheduledge flushing has stopped
+// Close does a final flush on return and returns any
+// error from the final flush if it occurs
 func (p *PointWriter) Close() error {
 	p.mu.Lock()
 
@@ -136,5 +138,5 @@ func (p *PointWriter) Close() error {
 	// wait until schedule exits
 	<-p.stopped
 
-	return nil
+	return p.w.Flush()
 }


Test patch:
diff --git a/writer/point_test.go b/writer/point_test.go
index a1c2bd2..9e2fde3 100644
--- a/writer/point_test.go
+++ b/writer/point_test.go
@@ -74,3 +74,23 @@ func Test_PointWriter_Write(t *testing.T) {
 		assert.Truef(t, delta <= 105*time.Millisecond, deltaMsgFmt, delta)
 	}
 }
+
+func Test_PointWriter_Close(t *testing.T) {
+	var (
+		underlyingWriter = newTestWriter()
+		// long flush interval to ensure flush called by close not interval
+		writer = NewPointWriter(NewBufferedWriter(underlyingWriter), 10*time.Second)
+		// 1 batch of 99 (smaller than buffer size 100)
+		expected = createNTestRowMetrics(t, 1, 99)
+	)
+
+	n, err := writer.Write(createTestRowMetrics(t, 99)...)
+	require.NoError(t, err)
+	require.Equal(t, 99, n)
+
+	// close writer ensuring no more flushes occur
+	require.NoError(t, writer.Close())
+
+	// check batches written to underlying writer are 100 batches of 100 metrics
+	require.Equal(t, expected, underlyingWriter.writes)
+}
Repository: influxdata/influxdb-client-go
Pull request #55 (2019-10-10 17:02:16)

Release v0.1.1
Merging develop into master for the `v0.1.1` release.

This includes a fix to the writes packages which ensures a final `Flush()` happens on `writer.Close()`


Patch:
diff --git a/writer/point.go b/writer/point.go
index 40682e1..0c813e4 100644
--- a/writer/point.go
+++ b/writer/point.go
@@ -121,6 +121,8 @@ func (p *PointWriter) Write(m ...influxdb.Metric) (int, error) {
 // Close signals to stop flushing metrics and causes subsequent
 // calls to Write to return a closed pipe error
 // Close returns once scheduledge flushing has stopped
+// Close does a final flush on return and returns any
+// error from the final flush if it occurs
 func (p *PointWriter) Close() error {
 	p.mu.Lock()
 
@@ -136,5 +138,5 @@ func (p *PointWriter) Close() error {
 	// wait until schedule exits
 	<-p.stopped
 
-	return nil
+	return p.w.Flush()
 }


Test patch:
diff --git a/writer/point_test.go b/writer/point_test.go
index a1c2bd2..9e2fde3 100644
--- a/writer/point_test.go
+++ b/writer/point_test.go
@@ -74,3 +74,23 @@ func Test_PointWriter_Write(t *testing.T) {
 		assert.Truef(t, delta <= 105*time.Millisecond, deltaMsgFmt, delta)
 	}
 }
+
+func Test_PointWriter_Close(t *testing.T) {
+	var (
+		underlyingWriter = newTestWriter()
+		// long flush interval to ensure flush called by close not interval
+		writer = NewPointWriter(NewBufferedWriter(underlyingWriter), 10*time.Second)
+		// 1 batch of 99 (smaller than buffer size 100)
+		expected = createNTestRowMetrics(t, 1, 99)
+	)
+
+	n, err := writer.Write(createTestRowMetrics(t, 99)...)
+	require.NoError(t, err)
+	require.Equal(t, 99, n)
+
+	// close writer ensuring no more flushes occur
+	require.NoError(t, writer.Close())
+
+	// check batches written to underlying writer are 100 batches of 100 metrics
+	require.Equal(t, expected, underlyingWriter.writes)
+}
Repository: influxdata/influxdb-client-go
Pull request #57 (2019-10-18 14:26:40)

Reorder arguments bucket and org in bucket writer
The order of the bucket and organization arguments is incorrect. The client takes a bucket before the org. Sadly my test was ensuring it was the wrong way around.

This reorders the arguments correctly.


Patch:
diff --git a/writer/writer.go b/writer/writer.go
index 5a4aa16..2a8ada6 100644
--- a/writer/writer.go
+++ b/writer/writer.go
@@ -9,7 +9,7 @@ import (
 // BucketMetricWriter is a type which Metrics can be written to a particular bucket
 // in a particular organisation
 type BucketMetricWriter interface {
-	Write(context.Context, string, string, ...influxdb.Metric) (int, error)
+	Write(ctx context.Context, bucket string, org string, m ...influxdb.Metric) (int, error)
 }
 
 // New constructs a point writer with an underlying buffer from the provided BucketMetricWriter
@@ -51,5 +51,5 @@ func NewBucketWriter(w BucketMetricWriter, bucket, org string) *BucketWriter {
 // Write writes the provided metrics to the underlying metrics writer
 // using the org and bucket configured on the bucket writer
 func (b *BucketWriter) Write(m ...influxdb.Metric) (int, error) {
-	return b.w.Write(b.ctxt, b.org, b.bucket, m...)
+	return b.w.Write(b.ctxt, b.bucket, b.org, m...)
 }


Test patch:
diff --git a/writer/writer_test.go b/writer/writer_test.go
index 1c02d3c..78f62cb 100644
--- a/writer/writer_test.go
+++ b/writer/writer_test.go
@@ -31,10 +31,10 @@ func Test_BucketWriter(t *testing.T) {
 		wr     = NewBucketWriter(spy, bucket, org)
 
 		expected = []bucketWriteCall{
-			{org, bucket, createTestRowMetrics(t, 4)},
-			{org, bucket, createTestRowMetrics(t, 8)},
-			{org, bucket, createTestRowMetrics(t, 12)},
-			{org, bucket, createTestRowMetrics(t, 16)},
+			{bucket, org, createTestRowMetrics(t, 4)},
+			{bucket, org, createTestRowMetrics(t, 8)},
+			{bucket, org, createTestRowMetrics(t, 12)},
+			{bucket, org, createTestRowMetrics(t, 16)},
 		}
 	)
Repository: influxdata/influxdb-client-go
Pull request #58 (2019-10-18 14:31:16)

Release v0.1.2
Cut a new v0.1.2 release containing the fix to bucket and org argument order.


Patch:
diff --git a/writer/writer.go b/writer/writer.go
index 5a4aa16..2a8ada6 100644
--- a/writer/writer.go
+++ b/writer/writer.go
@@ -9,7 +9,7 @@ import (
 // BucketMetricWriter is a type which Metrics can be written to a particular bucket
 // in a particular organisation
 type BucketMetricWriter interface {
-	Write(context.Context, string, string, ...influxdb.Metric) (int, error)
+	Write(ctx context.Context, bucket string, org string, m ...influxdb.Metric) (int, error)
 }
 
 // New constructs a point writer with an underlying buffer from the provided BucketMetricWriter
@@ -51,5 +51,5 @@ func NewBucketWriter(w BucketMetricWriter, bucket, org string) *BucketWriter {
 // Write writes the provided metrics to the underlying metrics writer
 // using the org and bucket configured on the bucket writer
 func (b *BucketWriter) Write(m ...influxdb.Metric) (int, error) {
-	return b.w.Write(b.ctxt, b.org, b.bucket, m...)
+	return b.w.Write(b.ctxt, b.bucket, b.org, m...)
 }


Test patch:
diff --git a/writer/writer_test.go b/writer/writer_test.go
index 1c02d3c..78f62cb 100644
--- a/writer/writer_test.go
+++ b/writer/writer_test.go
@@ -31,10 +31,10 @@ func Test_BucketWriter(t *testing.T) {
 		wr     = NewBucketWriter(spy, bucket, org)
 
 		expected = []bucketWriteCall{
-			{org, bucket, createTestRowMetrics(t, 4)},
-			{org, bucket, createTestRowMetrics(t, 8)},
-			{org, bucket, createTestRowMetrics(t, 12)},
-			{org, bucket, createTestRowMetrics(t, 16)},
+			{bucket, org, createTestRowMetrics(t, 4)},
+			{bucket, org, createTestRowMetrics(t, 8)},
+			{bucket, org, createTestRowMetrics(t, 12)},
+			{bucket, org, createTestRowMetrics(t, 16)},
 		}
 	)
Repository: influxdata/influxdb-client-go
Pull request #139 (2020-06-25 09:38:40)

fix: serialization of `\n`, `\r` and `\t` to Line Protocol
Related to https://github.com/influxdata/influxdb-client-java/issues/127

- [ ] CHANGELOG.md updated
- [x] Rebased/mergeable
- [x] Tests pass
- [x] Sign [CLA](https://influxdata.com/community/cla/) (if not already signed)


Patch:
diff --git a/api/write/ext.go b/api/write/ext.go
index 3014c05..e6e397e 100644
--- a/api/write/ext.go
+++ b/api/write/ext.go
@@ -75,6 +75,15 @@ func PointToLineProtocol(p *Point, precision time.Duration) string {
 func escapeKey(sb *strings.Builder, key string) {
 	for _, r := range key {
 		switch r {
+		case '\n':
+			sb.WriteString(`\\n`)
+			continue
+		case '\r':
+			sb.WriteString(`\\r`)
+			continue
+		case '\t':
+			sb.WriteString(`\\t`)
+			continue
 		case ' ', ',', '=':
 			sb.WriteString(`\`)
 		}


Test patch:
diff --git a/api/write/point_test.go b/api/write/point_test.go
index d2324e0..851cce1 100644
--- a/api/write/point_test.go
+++ b/api/write/point_test.go
@@ -261,6 +261,17 @@ func TestPrecision(t *testing.T) {
 	assert.Equal(t, line, "test,id=10 float64=80.1234567 60\n")
 }
 
+func TestTagEscapingKeyAndValue(t *testing.T) {
+	p := NewPointWithMeasurement("h\n2\no\t_data")
+	p.AddTag("new\nline", "new\nline")
+	p.AddTag("carriage\rreturn", "carriage\rreturn")
+	p.AddTag("t\tab", "t\tab")
+	p.AddField("level", 2)
+
+	line := PointToLineProtocol(p, time.Nanosecond)
+	assert.Equal(t, "h\\\\n2\\\\no\\\\t_data,new\\\\nline=new\\\\nline,carriage\\\\rreturn=carriage\\\\rreturn,t\\\\tab=t\\\\tab level=2i\n", line)
+}
+
 var s string
 
 func BenchmarkPointEncoderSingle(b *testing.B) {
Repository: influxdata/influxdb-client-go
Pull request #140 (2020-06-26 08:26:03)

fix: `=` is valid sign for measurement name
- [ ] CHANGELOG.md updated
- [x] Rebased/mergeable
- [x] Tests pass
- [x] Sign [CLA](https://influxdata.com/community/cla/) (if not already signed)


Patch:
diff --git a/api/write/ext.go b/api/write/ext.go
index e6e397e..629b498 100644
--- a/api/write/ext.go
+++ b/api/write/ext.go
@@ -16,22 +16,22 @@ import (
 // ToLineProtocol creates InfluxDB line protocol string from the Point, converting associated timestamp according to precision
 // and write result to the string builder
 func PointToLineProtocolBuffer(p *Point, sb *strings.Builder, precision time.Duration) {
-	escapeKey(sb, p.Name())
+	escapeKey(sb, p.Name(), false)
 	sb.WriteRune(',')
 	for i, t := range p.TagList() {
 		if i > 0 {
 			sb.WriteString(",")
 		}
-		escapeKey(sb, t.Key)
+		escapeKey(sb, t.Key, true)
 		sb.WriteString("=")
-		escapeKey(sb, t.Value)
+		escapeKey(sb, t.Value, true)
 	}
 	sb.WriteString(" ")
 	for i, f := range p.FieldList() {
 		if i > 0 {
 			sb.WriteString(",")
 		}
-		escapeKey(sb, f.Key)
+		escapeKey(sb, f.Key, true)
 		sb.WriteString("=")
 		switch f.Value.(type) {
 		case string:
@@ -72,7 +72,7 @@ func PointToLineProtocol(p *Point, precision time.Duration) string {
 	return sb.String()
 }
 
-func escapeKey(sb *strings.Builder, key string) {
+func escapeKey(sb *strings.Builder, key string, escapeEqual bool) {
 	for _, r := range key {
 		switch r {
 		case '\n':
@@ -84,8 +84,12 @@ func escapeKey(sb *strings.Builder, key string) {
 		case '\t':
 			sb.WriteString(`\\t`)
 			continue
-		case ' ', ',', '=':
+		case ' ', ',':
 			sb.WriteString(`\`)
+		case '=':
+			if escapeEqual {
+				sb.WriteString(`\`)
+			}
 		}
 		sb.WriteRune(r)
 	}


Test patch:
diff --git a/api/write/point_test.go b/api/write/point_test.go
index 851cce1..0ac27f5 100644
--- a/api/write/point_test.go
+++ b/api/write/point_test.go
@@ -272,6 +272,15 @@ func TestTagEscapingKeyAndValue(t *testing.T) {
 	assert.Equal(t, "h\\\\n2\\\\no\\\\t_data,new\\\\nline=new\\\\nline,carriage\\\\rreturn=carriage\\\\rreturn,t\\\\tab=t\\\\tab level=2i\n", line)
 }
 
+func TestEqualSignEscaping(t *testing.T) {
+	p := NewPointWithMeasurement("h=2o")
+	p.AddTag("l=ocation", "e=urope")
+	p.AddField("l=evel", 2)
+
+	line := PointToLineProtocol(p, time.Nanosecond)
+	assert.Equal(t, "h=2o,l\\=ocation=e\\=urope l\\=evel=2i\n", line)
+}
+
 var s string
 
 func BenchmarkPointEncoderSingle(b *testing.B) {
Repository: influxdata/influxdb-client-go
Pull request #191 (2020-08-18 12:32:59)

fix: boolDatatype not match line protocol
## Proposed Changes

fix [bug](https://github.com/influxdata/influxdb-client-go/issues/190): failed to parse boolean datatype in `QueryTableResult`.

## Checklist

- [x] CHANGELOG.md updated
- [x] Rebased/mergeable
- [x] A test has been added if appropriate
- [x] Tests pass
- [x] Commit messages are in [semantic format](https://seesparkbox.com/foundry/semantic_commit_messages)
- [x] Sign [CLA](https://influxdata.com/community/cla/) (if not already signed)



Patch:
diff --git a/CHANGELOG.md b/CHANGELOG.md
index 0b3c82c..fb0bc56 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,4 +1,7 @@
 ## 2.1.0 [in progress]
+### Bug fixes
+1. [#191](https://github.com/influxdata/influxdb-client-go/pull/191) Fixed QueryTableResult.Next() failed to parse boolean datatype.
+
 ### Documentation
 1. [#189](https://github.com/influxdata/influxdb-client-go/pull/189) Added clarification that server URL has to be the InfluxDB server base URL to API docs and all examples.   
 
diff --git a/api/query.go b/api/query.go
index 962db30..7fc54cb 100644
--- a/api/query.go
+++ b/api/query.go
@@ -32,7 +32,7 @@ import (
 const (
 	stringDatatype       = "string"
 	doubleDatatype       = "double"
-	boolDatatype         = "bool"
+	boolDatatype         = "boolean"
 	longDatatype         = "long"
 	uLongDatatype        = "unsignedLong"
 	durationDatatype     = "duration"


Test patch:
diff --git a/api/query_test.go b/api/query_test.go
index 4ce665c..f1f8a44 100644
--- a/api/query_test.go
+++ b/api/query_test.go
@@ -120,7 +120,7 @@ func TestQueryCVSResultMultiTables(t *testing.T) {
 ,,1,2020-02-17T22:19:49.747562847Z,2020-02-18T22:19:49.747562847Z,2020-02-18T10:34:08.135814545Z,4,i,test,1,adsfasdf
 ,,1,2020-02-17T22:19:49.747562847Z,2020-02-18T22:19:49.747562847Z,2020-02-18T22:08:44.850214724Z,-1,i,test,1,adsfasdf
 
-#datatype,string,long,dateTime:RFC3339,dateTime:RFC3339,dateTime:RFC3339,bool,string,string,string,string
+#datatype,string,long,dateTime:RFC3339,dateTime:RFC3339,dateTime:RFC3339,boolean,string,string,string,string
 #group,false,false,true,true,false,false,true,true,true,true
 #default,_result,,,,,,,,,
 ,result,table,_start,_stop,_time,_value,_field,_measurement,a,b
@@ -228,7 +228,7 @@ func TestQueryCVSResultMultiTables(t *testing.T) {
 			query.NewFluxColumnFull("dateTime:RFC3339", "", "_start", true, 2),
 			query.NewFluxColumnFull("dateTime:RFC3339", "", "_stop", true, 3),
 			query.NewFluxColumnFull("dateTime:RFC3339", "", "_time", false, 4),
-			query.NewFluxColumnFull("bool", "", "_value", false, 5),
+			query.NewFluxColumnFull("boolean", "", "_value", false, 5),
 			query.NewFluxColumnFull("string", "", "_field", true, 6),
 			query.NewFluxColumnFull("string", "", "_measurement", true, 7),
 			query.NewFluxColumnFull("string", "", "a", true, 8),