code: def run(self):
          
          self.group = async_chain(chain=self.chain[:], group=self.group, cached=self.cached, sync=self.sync,
                                   broker=self.broker)
          self.started = True
          return self.group
docs: Start queueing the chain to the worker cluster
          :return: the chain's group id