Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
request_deserializer=feast_dot_serving_dot_ServingService__pb2.GetFeastServingInfoRequest.FromString,
response_serializer=feast_dot_serving_dot_ServingService__pb2.GetFeastServingInfoResponse.SerializeToString,
),
'GetOnlineFeatures': grpc.unary_unary_rpc_method_handler(
servicer.GetOnlineFeatures,
request_deserializer=feast_dot_serving_dot_ServingService__pb2.GetOnlineFeaturesRequest.FromString,
response_serializer=feast_dot_serving_dot_ServingService__pb2.GetOnlineFeaturesResponse.SerializeToString,
),
'GetBatchFeatures': grpc.unary_unary_rpc_method_handler(
servicer.GetBatchFeatures,
request_deserializer=feast_dot_serving_dot_ServingService__pb2.GetBatchFeaturesRequest.FromString,
response_serializer=feast_dot_serving_dot_ServingService__pb2.GetBatchFeaturesResponse.SerializeToString,
),
'GetJob': grpc.unary_unary_rpc_method_handler(
servicer.GetJob,
request_deserializer=feast_dot_serving_dot_ServingService__pb2.GetJobRequest.FromString,
response_serializer=feast_dot_serving_dot_ServingService__pb2.GetJobResponse.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'feast.serving.ServingService', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
def reload(self):
"""
Reload the latest job status
Returns: None
"""
self.job_proto = self.serving_stub.GetJob(GetJobRequest(job=self.job_proto)).job
request_serializer=feast_dot_serving_dot_ServingService__pb2.GetFeastServingInfoRequest.SerializeToString,
response_deserializer=feast_dot_serving_dot_ServingService__pb2.GetFeastServingInfoResponse.FromString,
)
self.GetOnlineFeatures = channel.unary_unary(
'/feast.serving.ServingService/GetOnlineFeatures',
request_serializer=feast_dot_serving_dot_ServingService__pb2.GetOnlineFeaturesRequest.SerializeToString,
response_deserializer=feast_dot_serving_dot_ServingService__pb2.GetOnlineFeaturesResponse.FromString,
)
self.GetBatchFeatures = channel.unary_unary(
'/feast.serving.ServingService/GetBatchFeatures',
request_serializer=feast_dot_serving_dot_ServingService__pb2.GetBatchFeaturesRequest.SerializeToString,
response_deserializer=feast_dot_serving_dot_ServingService__pb2.GetBatchFeaturesResponse.FromString,
)
self.GetJob = channel.unary_unary(
'/feast.serving.ServingService/GetJob',
request_serializer=feast_dot_serving_dot_ServingService__pb2.GetJobRequest.SerializeToString,
response_deserializer=feast_dot_serving_dot_ServingService__pb2.GetJobResponse.FromString,
)