Handle worker status reports (replica managers only).
(
self, request: manager_pb2.StatusUpdate, context
)
| 159 | logging.debug("Termination executor stopped") |
| 160 | |
| 161 | def ReportStatus( |
| 162 | self, request: manager_pb2.StatusUpdate, context |
| 163 | ) -> manager_pb2.StatusUpdateResponse: |
| 164 | """Handle worker status reports (replica managers only).""" |
| 165 | try: |
| 166 | self._validate_role("replica_manager", "handle worker status reports") |
| 167 | return self._handle_worker_status(request, context) |
| 168 | except grpc.RpcError as e: |
| 169 | self._create_error_response(context, grpc.StatusCode.FAILED_PRECONDITION, str(e)) |
| 170 | raise |
| 171 | except Exception as e: |
| 172 | self._create_error_response(context, grpc.StatusCode.INTERNAL, f"Unexpected error: {e}") |
| 173 | raise |
| 174 | |
| 175 | def ReportReplicaStatus( |
| 176 | self, request: manager_pb2.ReplicaStatusUpdate, context |
nothing calls this directly
no test coverage detected