SubscribeProcessManageSignal
功能说明
接收客户端订阅进程控制信号请求。服务端为每一个任务分配一个消息队列，并侦听消息队列是否存在待发送的消息，若存在则通过gRPC stream发送给客户端。
函数原型
rpc SubscribeProcessManageSignal(ClientInfo) returns (stream ProcessManageSignal){}
输入参数说明
参数 |
类型（Protobuf定义） |
说明 |
|---|---|---|
ClientInfo |
message ClientInfo{ string jobId = 1; string role = 2; } |
ClientInfo.jobId：任务ID。 ClientInfo.role：客户端角色。 |
发送数据说明
参数 |
类型（Protobuf定义） |
说明 |
|---|---|---|
ProcessManageSignal |
message FaultRank{ string rankId = 1; string faultType = 2; } message ProcessManageSignal{ string uuid=1; string jobId = 2; string signalType = 3; repeated string actions = 4; repeated FaultRank faultRanks = 5; string changeStrategy = 6; int64 timeout = 7; } |
rankId：string类型，故障卡ID faultType：string类型，故障类型 uuid：string类型，本次signal的uuid jobId：string类型，训练的任务ID signalType ：string类型，signal类型 actions：repeated string，要执行的动作 faultRanks：repeated FaultRank，故障卡信息 changeStrategy：string类型，要执行的恢复策略 timeout：int64类型，超时时间 } |
返回值说明
返回值 |
类型（Protobuf定义） |
说明 |
|---|---|---|
stream |
grpc stream |
|