Skip to content

Commit

Permalink
Get call returns nothing if there is a 'matrix' and an 'in' clause fo…
Browse files Browse the repository at this point in the history
…r the key column. Closes #170
  • Loading branch information
kaidaguerre committed Sep 13, 2021
1 parent ff92832 commit 9e5cbd4
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 2 deletions.
3 changes: 2 additions & 1 deletion plugin/query_data.go
Original file line number Diff line number Diff line change
Expand Up @@ -117,8 +117,9 @@ func (d *QueryData) ShallowCopy() *QueryData {
FetchType: d.FetchType,
QueryContext: d.QueryContext,
Connection: d.Connection,
Matrix: d.Matrix,
ConnectionManager: d.ConnectionManager,
Matrix: d.Matrix,
filteredMatrix: d.filteredMatrix,
hydrateCalls: d.hydrateCalls,
concurrencyManager: d.concurrencyManager,
rowDataChan: d.rowDataChan,
Expand Down
2 changes: 1 addition & 1 deletion plugin/table_fetch.go
Original file line number Diff line number Diff line change
Expand Up @@ -180,7 +180,7 @@ func (t *Table) doGet(ctx context.Context, queryData *QueryData, hydrateItem int
// enables multi-partition fetching
func (t *Table) getForEach(ctx context.Context, queryData *QueryData, rd *RowData) (interface{}, error) {

log.Printf("[TRACE] getForEach, matrixItem list: %v\n", queryData.Matrix)
log.Printf("[TRACE] getForEach, matrixItem list: %v\n", queryData.filteredMatrix)

var wg sync.WaitGroup
errorChan := make(chan error, len(queryData.Matrix))
Expand Down

0 comments on commit 9e5cbd4

Please sign in to comment.