try removing datadog pin override

ExpediaGroup · Jan 31, 2024 · fe2af40 · fe2af40
1 parent 61d5820
commit fe2af40
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 6 deletions.
diff --git a/go/internal/feast/featurestore.go b/go/internal/feast/featurestore.go
@@ -60,7 +60,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.cluster.local:80", sanitizedProjectName, productName)
+  endpoint := fmt.Sprintf("%s-transformations.%s.svc.cluster.local:80", sanitizedProjectName, productName)
   transformationService, _ := transformation.NewGrpcTransformationService(config, endpoint)
 
 	return &FeatureStore{

diff --git a/sdk/python/feast/transformation_server.py b/sdk/python/feast/transformation_server.py
@@ -211,11 +211,6 @@ def TransformFeatures(self, request, context):
 def start_server(store: FeatureStore, port: int):
     log.info("Starting server..")
 
-    # Start Datadog tracing
-    patch(grpc=True)
-    custom_tracer = Tracer()
-    Pin.override(grpc.Server, service='TransformationService', tracer=custom_tracer)
-
     server = grpc.server(futures.ThreadPoolExecutor(max_workers=10))
     add_TransformationServiceServicer_to_server(TransformationServer(store), server)