fix: delay flux.FinalizeBuiltins as late as possible

influxdata · Nov 6, 2019 · dd0a4f1 · dd0a4f1
1 parent e5e57a7
commit dd0a4f1
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 5 deletions.
diff --git a/cmd/influx/query.go b/cmd/influx/query.go
@@ -5,7 +5,6 @@ import (
 	"fmt"
 
 	"github.com/influxdata/flux"
-
 	"github.com/influxdata/flux/repl"
 	_ "github.com/influxdata/flux/stdlib"
 	platform "github.com/influxdata/influxdb"
@@ -43,8 +42,6 @@ func init() {
 }
 
 func fluxQueryF(cmd *cobra.Command, args []string) error {
-	flux.FinalizeBuiltIns()
-
 	if flags.local {
 		return fmt.Errorf("local flag not supported for query command")
 	}
@@ -81,6 +78,8 @@ func fluxQueryF(cmd *cobra.Command, args []string) error {
 		orgID = o.ID
 	}
 
+	flux.FinalizeBuiltIns()
+
 	r, err := getFluxREPL(flags.host, flags.token, orgID)
 	if err != nil {
 		return fmt.Errorf("failed to get the flux REPL: %v", err)

diff --git a/cmd/influx/repl.go b/cmd/influx/repl.go
@@ -42,8 +42,6 @@ func init() {
 }
 
 func replF(cmd *cobra.Command, args []string) error {
-	flux.FinalizeBuiltIns()
-
 	if flags.local {
 		return fmt.Errorf("local flag not supported for repl command")
 	}
@@ -73,6 +71,8 @@ func replF(cmd *cobra.Command, args []string) error {
 		}
 	}
 
+	flux.FinalizeBuiltIns()
+
 	r, err := getFluxREPL(flags.host, flags.token, orgID)
 	if err != nil {
 		return err