public synchronized void sendTaskStatus ( final ReefServiceProtos . TaskStatusProto taskStatusProto ) { this . sendHeartBeat ( this . getEvaluatorHeartbeatProto ( this . evaluatorRuntime . get ( ) . getEvaluatorStatus ( ) , this . contextManager . get ( ) . getContextStatusCollection ( ) , Optional . of ( taskStatusProto ) ) ) ; }
Called with a specific TaskStatus that must be delivered to the driver .