Skip to content

Commit a43f87c

Browse files
committed
Search in the "parquet bucket" for single files
Need to rename later.
1 parent 08049dd commit a43f87c

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

internal/app/app.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -41,7 +41,7 @@ func New(settings config.Settings) (*App, error) {
4141
return nil, fmt.Errorf("failed to create ClickHouse connection: %w", err)
4242
}
4343
s3Client := s3ClientFromSettings(&settings)
44-
buckets := []string{settings.CloudEventBucket, settings.EphemeralBucket}
44+
buckets := []string{settings.CloudEventBucket, settings.EphemeralBucket, settings.ParquetBucket}
4545
eventService := eventrepo.New(chConn, s3Client, settings.ParquetBucket)
4646

4747
var identityClient identity.Client
@@ -120,7 +120,7 @@ func CreateGRPCServer(logger *zerolog.Logger, settings *config.Settings) (*grpc.
120120
s3Client := s3ClientFromSettings(settings)
121121
eventService := eventrepo.New(chConn, s3Client, settings.ParquetBucket)
122122

123-
rpcServer := rpc.NewServer([]string{settings.CloudEventBucket, settings.EphemeralBucket}, eventService)
123+
rpcServer := rpc.NewServer([]string{settings.CloudEventBucket, settings.EphemeralBucket, settings.ParquetBucket}, eventService)
124124

125125
grpcPanic := metrics.GRPCPanicker{Logger: logger}
126126
server := grpc.NewServer(

0 commit comments

Comments
 (0)