def stream_experiment_data(request, **kwargs):
    self.assertEqual(request.experiment_id, '789')
    self.assertEqual(kwargs['metadata'], grpc_util.version_metadata())
    response = export_service_pb2.StreamExperimentDataResponse()
    response.run_name = 'train'
    response.tag_name = 'batch_loss'
    response.points.steps.append(0)
    response.points.values.append(np.nan)
    response.points.wall_times.add(seconds=0, nanos=0)
    response.points.steps.append(1)
    response.points.values.append(np.inf)
    response.points.wall_times.add(seconds=10, nanos=0)
    (yield response)
def stream_experiment_data(request, **kwargs):
    self.assertEqual(request.experiment_id, '789')
    self.assertEqual(kwargs['metadata'], grpc_util.version_metadata())
    response = export_service_pb2.StreamExperimentDataResponse()
    response.run_name = 'train'
    response.tag_name = 'batch_loss'
    response.points.steps.append(0)
    response.points.values.append(np.nan)
    response.points.wall_times.add(seconds=0, nanos=0)
    response.points.steps.append(1)
    response.points.values.append(np.inf)
    response.points.wall_times.add(seconds=10, nanos=0)
    (yield response)