jprdonnelly/steampipe
1
0
Fork 0
mirror of https://github.com/turbot/steampipe.git synced 2026-05-08 00:02:09 -04:00
Code Issues Packages Projects Releases Wiki Activity

finally working

Browse Source
This commit is contained in:
Puskar Basu
2024-09-26 18:54:08 +05:30
parent df374cd6e0
commit 3bdc65c70d
4 changed files with 89 additions and 106 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
pkg/query/queryexecute/execute.go
View File

@@ -13,6 +13,7 @@ import (
"github.com/turbot/pipe-fittings/contexthelpers"
"github.com/turbot/pipe-fittings/modconfig"
"github.com/turbot/pipe-fittings/querydisplay"
"github.com/turbot/pipe-fittings/steampipeconfig"
"github.com/turbot/pipe-fittings/utils"
"github.com/turbot/steampipe/pkg/cmdconfig"
"github.com/turbot/steampipe/pkg/connection_sync"
@@ -108,7 +109,7 @@ func executeQuery(ctx context.Context, initData *query.InitData, resolvedQuery *
utils.LogTime("query.execute.executeQuery start")
defer utils.LogTime("query.execute.executeQuery end")
var snap *snapshot.SteampipeSnapshot
var snap *steampipeconfig.SteampipeSnapshot
// the db executor sends result data over resultsStreamer
resultsStreamer, err := db_common.ExecuteQuery(ctx, initData.Client, resolvedQuery.ExecuteSQL, resolvedQuery.Args...)