-
Notifications
You must be signed in to change notification settings - Fork 835
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
V2 Dataplane in Executor/Operator + Triton Server #2023
Conversation
Check out this pull request on Review Jupyter notebook visual diffs & provide feedback on notebooks. Powered by ReviewNB |
Sun Jun 28 07:49:59 UTC 2020 impatient try |
Sun Jun 28 07:50:59 UTC 2020 impatient try |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This looks great @cliveseldon!!!
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks for the awesome feature! Looking forward to it.
Fri Sep 4 18:06:11 UTC 2020 impatient try |
Fri Sep 4 18:06:10 UTC 2020 impatient try |
Sat Sep 5 07:17:50 UTC 2020 impatient try |
Sat Sep 5 07:17:54 UTC 2020 impatient try |
Sat Sep 5 08:23:25 UTC 2020 impatient try |
Sat Sep 5 08:23:34 UTC 2020 impatient try |
Sat Sep 5 10:40:42 UTC 2020 impatient try |
Sat Sep 5 10:40:42 UTC 2020 impatient try |
Tue Sep 22 10:47:05 UTC 2020 impatient try |
Tue Sep 22 10:47:12 UTC 2020 impatient try |
Tue Sep 22 12:46:06 UTC 2020 impatient try |
Tue Sep 22 12:46:09 UTC 2020 impatient try |
/test integration |
/test notebooks |
Tue Sep 22 13:07:41 UTC 2020 impatient try |
Tue Sep 22 13:07:52 UTC 2020 impatient try |
Tue Sep 22 19:32:53 UTC 2020 impatient try |
Tue Sep 22 19:32:55 UTC 2020 impatient try |
/test integration |
/test notebooks |
Tue Sep 22 22:38:05 UTC 2020 impatient try |
Tue Sep 22 22:38:28 UTC 2020 impatient try |
@cliveseldon: The following test failed, say
Instructions for interacting with me using PR comments are available here. If you have questions or suggestions related to my behavior, please file an issue against the jenkins-x/lighthouse repository. I understand the commands that are listed here. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Looks great! I added a couple of points/questions
executor/api/constants.go
Outdated
@@ -2,6 +2,7 @@ package api | |||
|
|||
const ProtocolSeldon = "seldon" | |||
const ProtocolTensorflow = "tensorflow" | |||
const ProtocolKFserving = "kfserving" |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Nit: KFserving -> KfServing/KFServing
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
they are all lowercase
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Oh i meant ProtocolKFserving -> ProtocolKFServing
grpc.WithInsecure(), | ||
} | ||
opts = append(opts, grpc2.AddClientInterceptors(s.Predictor, s.DeploymentName, modelName, s.annotations, s.Log)) | ||
conn, err := grpc.Dial(fmt.Sprintf("%s:%d", host, port), opts...) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Seems first iteration won't have ssl, which is reasonable - but may be worth mentioning briefly on docs or failing in the operator if ssl is enabled with protocl kfserving
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I don't see SSL on any of the grpc clients. Sounds like this is a wider issue to address?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Yeah sounds good, I think we can just open a gh issue
panic("implement me") | ||
} | ||
|
||
func (g GrpcKFServingServer) ModelMetadata(ctx context.Context, request *inference.ModelMetadataRequest) (*inference.ModelMetadataResponse, error) { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
It seems in the client, model metadata is not implemented, but metadata is - would this not be using th emodelMetadata function instead of the metadata function?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
As I understand it client modelMetaData is only used by the Seldon specific Graph Metadata call. But I agree this terminology is confusing.
executor/api/rest/server.go
Outdated
@@ -160,6 +159,12 @@ func (r *SeldonRestApi) Initialise() { | |||
r.Router.NewRoute().Path("/v1/models:predict").Methods("OPTIONS", "POST").HandlerFunc(r.wrapMetrics(metric.PredictionHttpServiceName, r.predictions)) // Nonstandard path - Seldon extension | |||
r.Router.NewRoute().Path("/v1/models/{"+ModelHttpPathVariable+"}").Methods("GET", "OPTIONS").HandlerFunc(r.wrapMetrics(metric.StatusHttpServiceName, r.status)) | |||
r.Router.NewRoute().Path("/v1/models/{"+ModelHttpPathVariable+"}/metadata").Methods("GET", "OPTIONS").HandlerFunc(r.wrapMetrics(metric.MetadataHttpServiceName, r.metadata)) | |||
case api.ProtocolKFserving: |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
It seems metadata is implemented but not defined here, is that intentional?
Wed Sep 23 07:59:01 UTC 2020 impatient try |
Wed Sep 23 07:59:10 UTC 2020 impatient try |
Wed Sep 23 08:42:19 UTC 2020 impatient try |
Wed Sep 23 08:42:29 UTC 2020 impatient try |
Wed Sep 23 08:45:33 UTC 2020 impatient try |
Wed Sep 23 08:46:23 UTC 2020 impatient try |
Fixes #1648