Skip to content

Commit

Permalink
Fix error for missing required quals. Closes #40
Browse files Browse the repository at this point in the history
  • Loading branch information
kaidaguerre committed Feb 22, 2021
1 parent 9cbf9de commit 54e5936
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions plugin/table_fetch.go
Original file line number Diff line number Diff line change
Expand Up @@ -44,7 +44,7 @@ func (t *Table) fetchItems(ctx context.Context, queryData *QueryData) error {
func (t *Table) executeGetCall(ctx context.Context, queryData *QueryData) (err error) {
logger := t.Plugin.Logger
// verify we have the necessary quals
if queryData.KeyColumnQuals == nil {
if len(queryData.KeyColumnQuals) == 0 {
return status.Error(codes.Internal, fmt.Sprintf("'Get' call requires an '=' qual for %s", t.Get.KeyColumns.ToString()))
}

Expand Down Expand Up @@ -240,7 +240,7 @@ func (t *Table) executeListCall(ctx context.Context, queryData *QueryData) {
}()

// verify we have the necessary quals
if t.List.KeyColumns != nil && queryData.KeyColumnQuals == nil {
if t.List.KeyColumns != nil && len(queryData.KeyColumnQuals) == 0 {
queryData.streamError(status.Error(codes.Internal, fmt.Sprintf("'List' call requires an '=' qual for %s", t.List.KeyColumns.ToString())))
}

Expand Down

0 comments on commit 54e5936

Please sign in to comment.