Show connection name along with error message. Closes #684

turbot · Nov 17, 2023 · 22758e4 · 22758e4
1 parent c38bb04
commit 22758e4
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/plugin/query_data.go b/plugin/query_data.go
@@ -19,6 +19,7 @@ import (
 	"github.com/turbot/steampipe-plugin-sdk/v5/plugin/quals"
 	"github.com/turbot/steampipe-plugin-sdk/v5/query_cache"
 	"github.com/turbot/steampipe-plugin-sdk/v5/rate_limiter"
+	"github.com/turbot/steampipe-plugin-sdk/v5/sperr"
 	"github.com/turbot/steampipe-plugin-sdk/v5/telemetry"
 	"golang.org/x/exp/maps"
 	"golang.org/x/sync/semaphore"
@@ -832,7 +833,7 @@ func (d *QueryData) streamRow(row *proto.Row) {
 
 func (d *QueryData) streamError(err error) {
 	log.Printf("[WARN] QueryData StreamError %v (%s)", err, d.connectionCallId)
-	d.errorChan <- err
+	d.errorChan <- sperr.WrapWithMessage(err, d.Connection.Name)
 }
 
 // TODO KAI this seems to get called even after cancellation