@classmethod
    def receiver(cls, f, **kwargs):
        def _receiver():
            for msg, args, kwargs in cls.receive():
                try:
                    f(msg, *args, **kwargs)
                except TaskletExit:
                    break
                except:
                    logging.exception("unhandled exception in Tasklet.receiver")
        return cls.new(_receiver, **kwargs)
This is a default post-process function for table cell value.
dataset/ETHPy150Open concurrence/concurrence/lib/concurrence/core.py/Tasklet.receiver--crossover with--dataset/ETHPy150Open openstack/rally/rally/task/processing/charts.py/Table._round