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? (#4773 could perhaps be used to allow an incremental rollout, or I could run this through the query log analyzer I made for #4776)
influxdata · Jun 21, 2022 · 570e0f3 · 570e0f3
1 parent 328b526
commit 570e0f3
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git 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":                                                       "fc44be19999d594ac7275bf4a8093233fc1dfba09c4b52a9aff4d08528fb2e19",
 	"stdlib/experimental/experimental_test.flux":                                                  "206cbb54d35da80a6736dec990219f5bbabcdc3c65fbb9d1041058c8aae3450d",
 	"stdlib/experimental/fill_test.flux":                                                          "626568ae94d54c4d7639813191b814af104594a4a4d66fd1d7d76c1c48767fc3",
 	"stdlib/experimental/first_test.flux":                                                         "3bd1ff03bac6a45a3c525abb5ded3377f08195b6a5094caa42c8fb8b96aa6268",

diff --git 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