Use GetEmptyAggregatorError from steampipe

v1.7.0-rc.2

Author: kaidaguerre

go.mod

@@ -8,21 +8,24 @@ require (
 	github.com/hashicorp/go-hclog v1.5.0
 	github.com/hashicorp/go-version v1.6.0 // indirect
 	github.com/turbot/go-kit v0.6.0-alpha.1
-	github.com/turbot/steampipe v0.20.0-alpha.6
+	// async_refresh
+	github.com/turbot/steampipe v1.7.0-rc.0.0.20230427143948-32b222151c67
 	github.com/turbot/steampipe-plugin-sdk/v5 v5.4.0-rc.1
 	go.opentelemetry.io/otel v1.10.0
 	google.golang.org/protobuf v1.30.0
 )
 
-require go.opentelemetry.io/otel/metric v0.30.0
+require (
+	github.com/Masterminds/semver/v3 v3.2.1
+	go.opentelemetry.io/otel/metric v0.30.0
+)
 
 require (
 	cloud.google.com/go v0.107.0 // indirect
 	cloud.google.com/go/compute v1.15.1 // indirect
 	cloud.google.com/go/compute/metadata v0.2.3 // indirect
 	cloud.google.com/go/iam v0.8.0 // indirect
 	cloud.google.com/go/storage v1.27.0 // indirect
-	github.com/Masterminds/semver/v3 v3.2.1 // indirect
 	github.com/aws/aws-sdk-go v1.44.183 // indirect
 	github.com/bgentry/go-netrc v0.0.0-20140422174119-9fd32a8b3d3d // indirect
 	github.com/briandowns/spinner v1.23.0 // indirect
@@ -179,5 +182,4 @@ replace (
 	github.com/deislabs/oras => github.com/oras-project/oras v0.9.0
 	github.com/docker/distribution => github.com/distribution/distribution v2.7.1+incompatible
 	github.com/docker/docker => github.com/moby/moby v20.10.17+incompatible
-
 )

go.sum

@@ -902,8 +902,8 @@ github.com/tmc/grpc-websocket-proxy v0.0.0-20190109142713-0ad062ec5ee5/go.mod h1
 github.com/tombuildsstuff/giovanni v0.15.1/go.mod h1:0TZugJPEtqzPlMpuJHYfXY6Dq2uLPrXf98D2XQSxNbA=
 github.com/turbot/go-kit v0.6.0-alpha.1 h1:mm1QpkwknuJQfA7oKzyzMiDRx5GsKlzxwsNa7n+Ttj4=
 github.com/turbot/go-kit v0.6.0-alpha.1/go.mod h1:oP9gLk6bETL4nkEuujZZbOlcv9jnHQlf7DYcI/+Ke8Q=
-github.com/turbot/steampipe v0.20.0-alpha.6 h1:jaDPTHKZyTzmyzV9wuthpO5a/evAVyWH9JMwBz5ntKg=
-github.com/turbot/steampipe v0.20.0-alpha.6/go.mod h1:hhpIN8ARXlBEqhrt5o4+5Y1cnXMT6C7ll+OxLp7hYXU=
+github.com/turbot/steampipe v1.7.0-rc.0.0.20230427143948-32b222151c67 h1:M6uDo97Mh7PTEu0IOuYMHSwLYB5sZHgowlO47u4bz/o=
+github.com/turbot/steampipe v1.7.0-rc.0.0.20230427143948-32b222151c67/go.mod h1:hhpIN8ARXlBEqhrt5o4+5Y1cnXMT6C7ll+OxLp7hYXU=
 github.com/turbot/steampipe-plugin-sdk/v5 v5.4.0-rc.1 h1:X1mJovPJLyCiLDe12CN+XLoXica0elNz0LltSShn/WI=
 github.com/turbot/steampipe-plugin-sdk/v5 v5.4.0-rc.1/go.mod h1:bfvdKaLwemr13EPOMbnr7/hOQOO7m4oM7HnVMdNotgY=
 github.com/ugorji/go v0.0.0-20180813092308-00b869d2f4a5/go.mod h1:hnLbHMwcvSihnDhEfx2/BzKp2xb0Y+ErdfYcrs9tkJQ=

hub/errors.go

@@ -2,6 +2,7 @@ package hub
 
 import (
 	"context"
+	"errors"
 	"fmt"
 	"log"
 	"os"
@@ -503,7 +504,7 @@ func (h *Hub) startScanForConnection(connectionName string, table string, qualMa
 		connectionNames = connectionConfig.GetResolveConnectionNames()
 		// if there are no connections, do not proceed
 		if len(connectionNames) == 0 {
-			return nil, getEmptyAggregatorError(connectionConfig)
+			return nil, errors.New(connectionConfig.GetEmptyAggregatorError())
 		}
 	}
 

hub/hub.go

@@ -15,7 +15,7 @@ var fdwVersion = "1.7.0"
 // A pre-release marker for the version. If this is "" (empty string)
 // then it means that it is a final release. Otherwise, this is a pre-release
 // such as "dev" (in development), "beta", "rc1", etc.
-var prerelease = "rc.1"
+var prerelease = "rc.2"
 
 // FdwVersion is an instance of semver.Version. This has the secondary
 // benefit of verifying during tests and init time that our version is a