From fd4922ac5cb197d524af8c85b76ad9dc27973f66 Mon Sep 17 00:00:00 2001
From: Markus Westerlind <mwesterlind@influxdata.com>
Date: Tue, 21 Jun 2022 15:46:55 +0200
Subject: [PATCH] fix: Add required fields to the signature of experimental/to

The documentation implies that these fields are mandatory to call this function and looking at the implementation it will indeed error if they are missing. Changing this is still technically a breaking change so maybe we want some caution before merging this? (https://github.com/influxdata/flux/pull/4773 could perhaps be used to allow an incremental rollout, or I could run this through the query log analyzer I made for https://github.com/influxdata/flux/pull/4776)
---
 libflux/go/libflux/buildinfo.gen.go   | 2 +-
 runtime/lookup_test.go                | 2 +-
 stdlib/experimental/experimental.flux | 4 ++--
 3 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/libflux/go/libflux/buildinfo.gen.go b/libflux/go/libflux/buildinfo.gen.go
index d398da7896..79491c0643 100644
--- a/libflux/go/libflux/buildinfo.gen.go
+++ b/libflux/go/libflux/buildinfo.gen.go
@@ -154,7 +154,7 @@ var sourceHashes = map[string]string{
 	"stdlib/experimental/count_test.flux":                                                         "120a145eb287266e35638cc5220f5cecf0eee5bf2eec1bb1e9852e7d382050c7",
 	"stdlib/experimental/csv/csv.flux":                                                            "94ae72b5fb50b8d65e9b384aebaa890f04bc914bb344ea751a64f729b5c849fe",
 	"stdlib/experimental/distinct_test.flux":                                                      "6d2891556d985d16ac9bd33176dd527bb34246afa1ac81dde65f1335885b6b02",
-	"stdlib/experimental/experimental.flux":                                                       "5543ad639409a8b1dcef963687eebb45c688d304fb9aa9e2d7f2186b1330d19d",
+	"stdlib/experimental/experimental.flux":                                                       "9c9cafd33bf7c5fb4b5a395358c137b19b40981b50ba03b4a48d04f36dfd5856",
 	"stdlib/experimental/experimental_test.flux":                                                  "206cbb54d35da80a6736dec990219f5bbabcdc3c65fbb9d1041058c8aae3450d",
 	"stdlib/experimental/fill_test.flux":                                                          "626568ae94d54c4d7639813191b814af104594a4a4d66fd1d7d76c1c48767fc3",
 	"stdlib/experimental/first_test.flux":                                                         "3bd1ff03bac6a45a3c525abb5ded3377f08195b6a5094caa42c8fb8b96aa6268",
diff --git a/runtime/lookup_test.go b/runtime/lookup_test.go
index 869fe6c71b..d80c179e73 100644
--- a/runtime/lookup_test.go
+++ b/runtime/lookup_test.go
@@ -64,7 +64,7 @@ func TestLookupComplexTypes(t *testing.T) {
 			path: "experimental",
 			id:   "to",
 			name: "lookup experimental.to",
-			want: "(?bucket: string, ?bucketID: string, ?host: string, ?org: string, ?orgID: string, <-tables: stream[A], ?token: string) => stream[A]",
+			want: "(?bucket: string, ?bucketID: string, ?host: string, ?org: string, ?orgID: string, <-tables: stream[{A with _measurement: string, _time: time}], ?token: string) => stream[{A with _measurement: string, _time: time}]",
 		},
 		{
 			path: "http",
diff --git a/stdlib/experimental/experimental.flux b/stdlib/experimental/experimental.flux
index 754580abff..43c8baf117 100644
--- a/stdlib/experimental/experimental.flux
+++ b/stdlib/experimental/experimental.flux
@@ -301,14 +301,14 @@ builtin set : (<-tables: stream[A], o: B) => stream[C] where A: Record, B: Recor
 // tags: outputs
 //
 builtin to : (
-        <-tables: stream[A],
+        <-tables: stream[{A with _measurement: string, _time: time}],
         ?bucket: string,
         ?bucketID: string,
         ?org: string,
         ?orgID: string,
         ?host: string,
         ?token: string,
-    ) => stream[A]
+    ) => stream[{A with _measurement: string, _time: time}]
     where
     A: Record