11package main
22
33import (
4- "context"
54 "fmt"
6- "time"
75
8- "github.com/openshift/sippy/pkg/api"
9- bqcachedclient "github.com/openshift/sippy/pkg/bigquery"
106 log "github.com/sirupsen/logrus"
117 "github.com/spf13/cobra"
128 "github.com/spf13/pflag"
@@ -18,25 +14,19 @@ import (
1814
1915type VariantSnapshotFlags struct {
2016 Path string
21- BigQueryFlags * flags.BigQueryFlags
22- GoogleCloudFlags * flags.GoogleCloudFlags
2317 ConfigFlags * configflags.ConfigFlags
2418 ComponentReadinessFlags * flags.ComponentReadinessFlags
2519}
2620
2721func NewVariantSnapshotFlags () * VariantSnapshotFlags {
2822 return & VariantSnapshotFlags {
29- BigQueryFlags : flags .NewBigQueryFlags (),
30- GoogleCloudFlags : flags .NewGoogleCloudFlags (),
3123 ConfigFlags : configflags .NewConfigFlags (),
3224 ComponentReadinessFlags : flags .NewComponentReadinessFlags (),
3325 Path : "pkg/variantregistry/snapshot.yaml" ,
3426 }
3527}
3628
3729func (f * VariantSnapshotFlags ) BindFlags (fs * pflag.FlagSet ) {
38- f .BigQueryFlags .BindFlags (fs )
39- f .GoogleCloudFlags .BindFlags (fs )
4030 f .ConfigFlags .BindFlags (fs )
4131 f .ComponentReadinessFlags .BindFlags (fs )
4232 fs .StringVar (& f .Path , "out" , f .Path , "Path to write results to" )
@@ -53,24 +43,12 @@ func NewVariantSnapshotCommand() *cobra.Command {
5343 return fmt .Errorf ("--config is required" )
5444 }
5545
56- ctx , cancel := context .WithTimeout (context .Background (), time .Minute * 10 )
57- defer cancel ()
58-
5946 cfg , err := f .ConfigFlags .GetConfig ()
6047 if err != nil {
6148 return err
6249 }
6350
64- opCtx , ctx := bqcachedclient .OpCtxForCronEnv (ctx , "variants snapshot" )
65- bqClient , err := f .BigQueryFlags .GetBigQueryClient (ctx , opCtx , nil , f .GoogleCloudFlags .ServiceAccountCredentialFile )
66- if err != nil {
67- return fmt .Errorf ("error getting BigQuery client: %w" , err )
68- }
69- releaseConfigs , err := api .GetReleasesFromBigQuery (ctx , bqClient )
70- if err != nil {
71- return fmt .Errorf ("error loading releases from BigQuery: %w" , err )
72- }
73- syntheticReleaseJobOverrides , err := variantregistry .BuildSyntheticReleaseJobOverrides (cfg .Releases , releaseConfigs )
51+ syntheticReleaseJobOverrides , err := variantregistry .BuildSyntheticReleaseJobOverrides (cfg .Releases )
7452 if err != nil {
7553 return fmt .Errorf ("error building synthetic release job overrides: %w" , err )
7654 }
0 commit comments