From 81d131088f46b65ad73d52d9690d50b8c06fc104 Mon Sep 17 00:00:00 2001 From: William Parsley Date: Tue, 2 Jan 2024 17:38:08 -0600 Subject: [PATCH] fix linting and indenting problems --- go/internal/feast/featurestore.go | 2 +- go/internal/feast/transformation/transformation_service.go | 6 +++--- sdk/python/feast/transformation_server.py | 4 ++-- 3 files changed, 6 insertions(+), 6 deletions(-) diff --git a/go/internal/feast/featurestore.go b/go/internal/feast/featurestore.go index c1a848561a..650cebfc23 100644 --- a/go/internal/feast/featurestore.go +++ b/go/internal/feast/featurestore.go @@ -61,7 +61,7 @@ func NewFeatureStore(config *registry.RepoConfig, callback transformation.Transf sanitizedProjectName := strings.Replace(config.Project, "_", "-", -1) productName := os.Getenv("PRODUCT") endpoint := fmt.Sprintf("%s-transformations.%s.svc.cluster.local:80", sanitizedProjectName, productName) - transformationService, _ := transformation.NewGrpcTransformationService(config, endpoint) + transformationService, _ := transformation.NewGrpcTransformationService(config, endpoint) return &FeatureStore{ config: config, diff --git a/go/internal/feast/transformation/transformation_service.go b/go/internal/feast/transformation/transformation_service.go index 42dc93a10d..51dc5d2990 100644 --- a/go/internal/feast/transformation/transformation_service.go +++ b/go/internal/feast/transformation/transformation_service.go @@ -64,11 +64,11 @@ func (s *GrpcTransformationService) GetTransformation( inputColumns = append(inputColumns, arr) } - inputSchema := arrow.NewSchema(inputFields, nil) + inputSchema := arrow.NewSchema(inputFields, nil) inputRecord := array.NewRecord(inputSchema, inputColumns, int64(numRows)) defer inputRecord.Release() - recordValueWriter := new(ByteSliceWriter) + recordValueWriter := new(ByteSliceWriter) arrowWriter, err := ipc.NewFileWriter(recordValueWriter, ipc.WithSchema(inputSchema)) if err != nil { return nil, err @@ -122,7 +122,7 @@ func ExtractTransformationResponse( for idx, field := range outRecord.Schema().Fields() { dropFeature := true - featureName := strings.Split(field.Name, "__")[1] + featureName := strings.Split(field.Name, "__")[1] if featureView.Base.Projection != nil { for _, feature := range featureView.Base.Projection.Features { diff --git a/sdk/python/feast/transformation_server.py b/sdk/python/feast/transformation_server.py index 8a8a428b79..53c7820136 100644 --- a/sdk/python/feast/transformation_server.py +++ b/sdk/python/feast/transformation_server.py @@ -1,11 +1,11 @@ import collections -import grpc import logging -import pyarrow as pa import sys import threading from concurrent import futures +import grpc +import pyarrow as pa from grpc_reflection.v1alpha import reflection from feast.errors import OnDemandFeatureViewNotFoundException