openfl/transport/grpc/director_server.py
async def WaitExperiment(self, request_iterator, context):  # NOQA:N802
        """Request for wait an experiment."""
        logger.info('Request WaitExperiment has got!')
        async for msg in request_iterator:
            logger.info(msg)
            experiment_name = await self.director.wait_experiment(msg.collaborator_name)
            logger.info(f'Experiment {experiment_name} was prepared')

            yield director_pb2.WaitExperimentResponse(experiment_name=experiment_name)
Request for wait an experiment.
Request for wait an experiment.
Request for wait an experiment .
async def WaitExperiment(self, request_iterator, context):  
        logger.info('Request WaitExperiment has got!')
        async for msg in request_iterator:
            logger.info(msg)
            experiment_name = await self.director.wait_experiment(msg.collaborator_name)
            logger.info(f'Experiment {experiment_name} was prepared')
            yield director_pb2.WaitExperimentResponse(experiment_name=experiment_name)
async def WaitExperiment ( self , request_iterator , context ) : logger . info ( 'Request WaitExperiment has got!' ) async for msg in request_iterator : logger . info ( msg ) experiment_name = await self . director . wait_experiment ( msg . collaborator_name ) logger . info ( f'Experiment {experiment_name} was prepared' ) yield director_pb2 . WaitExperimentResponse ( experiment_name = experiment_name )
Request for wait an experiment.
Request for wait an experiment .
# NOQA:N802 """Request for wait an experiment."""
self
request_iterator
context