Skip to content

Commit

Permalink
fix linting and indenting problems
Browse files Browse the repository at this point in the history
  • Loading branch information
William Parsley committed Jan 2, 2024
1 parent a4bb0ec commit 81d1310
Show file tree
Hide file tree
Showing 3 changed files with 6 additions and 6 deletions.
2 changes: 1 addition & 1 deletion go/internal/feast/featurestore.go
Original file line number Diff line number Diff line change
Expand Up @@ -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,
Expand Down
6 changes: 3 additions & 3 deletions go/internal/feast/transformation/transformation_service.go
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down Expand Up @@ -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 {
Expand Down
4 changes: 2 additions & 2 deletions sdk/python/feast/transformation_server.py
Original file line number Diff line number Diff line change
@@ -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
Expand Down

0 comments on commit 81d1310

Please sign in to comment.