openfl/transport/grpc/director_server.py
async def CollaboratorHealthCheck(self, request, context):  # NOQA:N802
        """Accept health check from envoy."""
        logger.debug(f'Request CollaboratorHealthCheck has got: {request}')
        health_check_period = self.director.collaborator_health_check(
            collaborator_name=request.name,
            is_experiment_running=request.is_experiment_running,
        )
        resp = director_pb2.CollaboratorHealthCheckResponse()
        resp.health_check_period.seconds = health_check_period

        return resp
Accept health check from envoy.
Accept health check from envoy.
Accept health check from envoy .
async def CollaboratorHealthCheck(self, request, context):  
        logger.debug(f'Request CollaboratorHealthCheck has got: {request}')
        health_check_period = self.director.collaborator_health_check(
            collaborator_name=request.name,
            is_experiment_running=request.is_experiment_running,
        )
        resp = director_pb2.CollaboratorHealthCheckResponse()
        resp.health_check_period.seconds = health_check_period
        return resp
async def CollaboratorHealthCheck ( self , request , context ) : logger . debug ( f'Request CollaboratorHealthCheck has got: {request}' ) health_check_period = self . director . collaborator_health_check ( collaborator_name = request . name , is_experiment_running = request . is_experiment_running , ) resp = director_pb2 . CollaboratorHealthCheckResponse ( ) resp . health_check_period . seconds = health_check_period return resp
Accept health check from envoy.
Accept health check from envoy .
# NOQA:N802 """Accept health check from envoy."""
self
request
context