code: def Schedule(self, tasks, mutation_pool, timestamp=None):
      
      non_fleetspeak_tasks = []
      for queue, queued_tasks in iteritems(
          collection.Group(tasks, lambda x: x.queue)):
        if not queue:
          continue
  
        client_id = _GetClientIdFromQueue(queue)
        if fleetspeak_utils.IsFleetspeakEnabledClient(
            client_id, token=self.token):
          for task in queued_tasks:
            fleetspeak_utils.SendGrrMessageThroughFleetspeak(client_id, task)
          continue
        non_fleetspeak_tasks.extend(queued_tasks)
  
      timestamp = timestamp or self.frozen_timestamp
      mutation_pool.QueueScheduleTasks(non_fleetspeak_tasks, timestamp)
docs: Schedule a set of Task() instances.