Skip to content

Commit

Permalink
trying to fix pt.3
Browse files Browse the repository at this point in the history
  • Loading branch information
heavycrystal committed Dec 20, 2023
1 parent 7d12f41 commit dbe2ad6
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions flow/e2e/bigquery/bigquery_helper.go
Original file line number Diff line number Diff line change
Expand Up @@ -453,7 +453,7 @@ func (b *BigQueryTestHelper) CreateTable(tableName string, schema *model.QRecord
return nil
}

func (b *BigQueryTestHelper) RunIntQuery(query string) (int64, error) {
func (b *BigQueryTestHelper) RunIntQuery(query string) (int, error) {
recordBatch, err := b.ExecuteAndProcessQuery(query)
if err != nil {
return 0, fmt.Errorf("could not execute query: %w", err)
Expand All @@ -462,5 +462,5 @@ func (b *BigQueryTestHelper) RunIntQuery(query string) (int64, error) {
return 0, fmt.Errorf("expected only 1 record, got %d", recordBatch.NumRecords)
}

return recordBatch.Records[0].Entries[0].Value.(int64), nil
return int(recordBatch.Records[0].Entries[0].Value.(int64)), nil
}

0 comments on commit dbe2ad6

Please sign in to comment.