def __call__(self, time_scale=1):
        reduce_f = lambda x, y: self.a(x, y,
                                       sleep=1.5 * time_scale,
                                       identity=(x, y) % 'reduce %s %s')
        t = map(lambda x: x * time_scale, [0.5, 1.5, 1.0, 6.0, 5.0, 2.0])
        map_f = lambda x, sleep: self.a(x, sleep=sleep, identity='map %s' % x)
        results = map(map_f, range(1, 7), t)
        return parallel_reduce(reduce_f, results)
dataset/ETHPy150Open severb/flowy/tests/examples.py/ParallelMapReduce.__call__/swapped operands of `%`