'Set some data that will be passed to all subsequent jobs without
needing to be transmitted every time. You must call this method before
queueing any jobs, otherwise the behavior is undefined. You can call it
after all jobs are done, then it will be used for the new round of
jobs. Can raise the :class:`Failure` exception is data could not be
sent to workers.'

def set_common_data(self, data=None):

    if self.failed:
        raise Failure(self.terminal_failure)
    self.events.put(data)
