This is an automated email from the ASF dual-hosted git repository.
manirajv06 pushed a commit to branch master
in repository
https://gitbox.apache.org/repos/asf/yunikorn-scheduler-interface.git
The following commit(s) were added to refs/heads/master by this push:
new 8130eeb [YUNIKORN-3433] Send the plugin errors back to core (#173)
8130eeb is described below
commit 8130eeb0b35b0c990a59d9e835bb6b3306ecb0be
Author: Manikandan R <[email protected]>
AuthorDate: Thu Sep 17 10:37:24 2026 +0530
[YUNIKORN-3433] Send the plugin errors back to core (#173)
Closes: #173
Signed-off-by: Manikandan R <[email protected]>
---
lib/go/si/si.pb.go | 14 ++++++++++++--
scheduler-interface-spec.md | 2 ++
si.proto | 2 ++
3 files changed, 16 insertions(+), 2 deletions(-)
diff --git a/lib/go/si/si.pb.go b/lib/go/si/si.pb.go
index 7b31a35..e294b8d 100644
--- a/lib/go/si/si.pb.go
+++ b/lib/go/si/si.pb.go
@@ -2327,6 +2327,8 @@ type PreFilterPredicatesResponse struct {
Success bool `protobuf:"varint,1,opt,name=success,proto3"
json:"success,omitempty"`
// map of nodes that are considered feasible to run the container.
Empty map means all nodes are eligible.
FeasibleNodes map[string]*Empty
`protobuf:"bytes,2,rep,name=FeasibleNodes,proto3"
json:"FeasibleNodes,omitempty" protobuf_key:"bytes,1,opt,name=key"
protobuf_val:"bytes,2,opt,name=value"`
+ // errors, if any
+ ErrorMessage string `protobuf:"bytes,3,opt,name=errorMessage,proto3"
json:"errorMessage,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
@@ -2375,6 +2377,13 @@ func (x *PreFilterPredicatesResponse) GetFeasibleNodes()
map[string]*Empty {
return nil
}
+func (x *PreFilterPredicatesResponse) GetErrorMessage() string {
+ if x != nil {
+ return x.ErrorMessage
+ }
+ return ""
+}
+
type UpdateContainerSchedulingStateRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
// application ID
@@ -2800,10 +2809,11 @@ const
file_yunikorn_scheduler_interface_si_proto_rawDesc = "" +
"\x1cPreemptionPredicatesResponse\x12\x18\n" +
"\asuccess\x18\x01 \x01(\bR\asuccess\x12\x14\n" +
"\x05index\x18\x02 \x01(\x05R\x05index\"\a\n" +
- "\x05Empty\"\xe4\x01\n" +
+ "\x05Empty\"\x88\x02\n" +
"\x1bPreFilterPredicatesResponse\x12\x18\n" +
"\asuccess\x18\x01 \x01(\bR\asuccess\x12[\n" +
- "\rFeasibleNodes\x18\x02
\x03(\v25.si.v1.PreFilterPredicatesResponse.FeasibleNodesEntryR\rFeasibleNodes\x1aN\n"
+
+ "\rFeasibleNodes\x18\x02
\x03(\v25.si.v1.PreFilterPredicatesResponse.FeasibleNodesEntryR\rFeasibleNodes\x12\"\n"
+
+ "\ferrorMessage\x18\x03 \x01(\tR\ferrorMessage\x1aN\n" +
"\x12FeasibleNodesEntry\x12\x10\n" +
"\x03key\x18\x01 \x01(\tR\x03key\x12\"\n" +
"\x05value\x18\x02
\x01(\v2\f.si.v1.EmptyR\x05value:\x028\x01\"\xc6\x02\n" +
diff --git a/scheduler-interface-spec.md b/scheduler-interface-spec.md
index 279da64..519e48b 100644
--- a/scheduler-interface-spec.md
+++ b/scheduler-interface-spec.md
@@ -757,6 +757,8 @@ message PreFilterPredicatesResponse{
bool success = 1;
// map of nodes that are considered feasible to run the container. Empty map
means all nodes are eligible.
map<string, Empty> FeasibleNodes = 2;
+ // errors, if any
+ string errorMessage = 3;
}
message UpdateContainerSchedulingStateRequest {
diff --git a/si.proto b/si.proto
index 3c4dd0c..f7e6ca1 100644
--- a/si.proto
+++ b/si.proto
@@ -399,6 +399,8 @@ message PreFilterPredicatesResponse{
bool success = 1;
// map of nodes that are considered feasible to run the container. Empty map
means all nodes are eligible.
map<string, Empty> FeasibleNodes = 2;
+ // errors, if any
+ string errorMessage = 3;
}
message UpdateContainerSchedulingStateRequest {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
