def send_batch(self, events):
        r = redis.StrictRedis(
            host=self.redis_host,
            port=self.redis_port,
        )

        pipe = r.pipeline()

        for event_tuple in events:
            event = event_tuple[0]
            # event_set = event_tuple[1]

            pipe.set("{0}".format(
                event["data"]["jid"]),
                event["data"]["return"],
            )

        pipe.execute()
Get all events
dataset/ETHPy150Open felskrone/salt-eventsd/doc/share/doc/eventsd_workers/Minion_Batch_Return_Worker.py/Minion_Batch_Return_Worker.send_batch