Skip to content

Commit

Permalink
more debug output
Browse files Browse the repository at this point in the history
  • Loading branch information
William Parsley committed Dec 14, 2023
1 parent 03d7a52 commit ed4bb8b
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions go/internal/feast/transformation/transformation_service.go
Original file line number Diff line number Diff line change
Expand Up @@ -111,17 +111,16 @@ func ExtractTransformationResponse(
arrowMemory := memory.NewGoAllocator()
arrowReader, err := ipc.NewFileReader(bytes.NewReader(arrowBytes), ipc.WithAllocator(arrowMemory))
if err != nil {
fmt.Println("Error allocating NewFileReader (ExtractTransformationResponse)")
return nil, err
}

outRecord, err := arrowReader.Read()
if err != nil {
fmt.Println("Error reading arrow record (ExtractTransformationResponse)")
return nil, err
}
result := make([]*onlineserving.FeatureVector, 0)
for idx, field := range outRecord.Schema().Fields() {
fmt.Println(field.Name)
dropFeature := true

if featureView.Base.Projection != nil {
Expand All @@ -142,6 +141,7 @@ func ExtractTransformationResponse(
}

if dropFeature {
fmt.Println("Dropped!!")
continue
}

Expand Down

0 comments on commit ed4bb8b

Please sign in to comment.