diff options
| author | Taras Madan <tarasmadan@google.com> | 2024-08-14 12:48:17 +0200 |
|---|---|---|
| committer | Taras Madan <tarasmadan@google.com> | 2024-08-14 11:45:46 +0000 |
| commit | f4c454d3823b7a6b645f3fb1585b4af4411b11a3 (patch) | |
| tree | ad69dda2aaf362e2e89e451666b9a988f045bb79 /pkg | |
| parent | 36c49360cfb68ea99dfdad8f70d5df72a2b3f99f (diff) | |
all: fix EnableStorageReadClient errors processing
Diffstat (limited to 'pkg')
| -rw-r--r-- | pkg/covermerger/bq_csv_reader.go | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/pkg/covermerger/bq_csv_reader.go b/pkg/covermerger/bq_csv_reader.go index d1bf77881..42a1fd4ec 100644 --- a/pkg/covermerger/bq_csv_reader.go +++ b/pkg/covermerger/bq_csv_reader.go @@ -46,10 +46,12 @@ func (r *bqCSVReader) InitNsRecords(ctx context.Context, ns, filePath string, fr gsPath := fmt.Sprintf("bq-exports/%s", sessionUUID) gsURI := "gs://" + gsBucket + "/" + gsPath + "/*.csv.gz" client, err := bigquery.NewClient(ctx, "syzkaller") - client.EnableStorageReadClient(ctx) if err != nil { return fmt.Errorf("failed to initialize bigquery client: %w", err) } + if err := client.EnableStorageReadClient(ctx); err != nil { + return fmt.Errorf("failed to client.EnableStorageReadClient: %w", err) + } q := client.Query(fmt.Sprintf(` EXPORT DATA OPTIONS ( |