code: def insert(self, task, args=[], kwargs={}, delay_seconds=0):
      
      body = {
        "payload": task.payload(),
        "queueName": self._queue_name,
        "groupByTag": True,
        "tag": task.__class__.__name__
      }
  
      def cloud_insertion(api):
        api.insert(body, delay_seconds)
  
      if len(self._threads):
        self.put(cloud_insertion)
      else:
        cloud_insertion(self._api)
  
      return self
docs: Insert a task into an existing queue.