openfl/transport/grpc/director_server.py
async def StreamMetrics(self, request, context):  # NOQA:N802
        """Request to stream metrics from the aggregator to frontend."""
        logger.info(f'Request StreamMetrics for {request.experiment_name} experiment has got!')

        caller = self.get_caller(context)
        async for metric_dict in self.director.stream_metrics(
                experiment_name=request.experiment_name, caller=caller
        ):
            if metric_dict is None:
                await asyncio.sleep(1)
                continue
            yield director_pb2.StreamMetricsResponse(**metric_dict)
Request to stream metrics from the aggregator to frontend.
Request to stream metrics from the aggregator to frontend.
Request to stream metrics from the aggregator to frontend .
async def StreamMetrics(self, request, context):  
        logger.info(f'Request StreamMetrics for {request.experiment_name} experiment has got!')
        caller = self.get_caller(context)
        async for metric_dict in self.director.stream_metrics(
                experiment_name=request.experiment_name, caller=caller
        ):
            if metric_dict is None:
                await asyncio.sleep(1)
                continue
            yield director_pb2.StreamMetricsResponse(**metric_dict)
async def StreamMetrics ( self , request , context ) : logger . info ( f'Request StreamMetrics for {request.experiment_name} experiment has got!' ) caller = self . get_caller ( context ) async for metric_dict in self . director . stream_metrics ( experiment_name = request . experiment_name , caller = caller ) : if metric_dict is None : await asyncio . sleep ( 1 ) continue yield director_pb2 . StreamMetricsResponse ( ** metric_dict )
Request to stream metrics from the aggregator to frontend.
Request to stream metrics from the aggregator to frontend .
# NOQA:N802 """Request to stream metrics from the aggregator to frontend."""
self
request
context