code: def do_orchestrate(self, group):
          
  
          log.debug("Starting orchestration run for worker group %s" % group["_id"])
  
          agents = self.fetch_worker_group_agents(group)
  
          # Evaluate what workers are currently, rightfully there. They won't be touched.
          for agent in agents:
              desired_workers = self.get_desired_workers_for_agent(group, agent)
              agent["new_desired_workers"] = []
              agent["new_desired_workers"] = desired_workers
  
          for agent in agents:
              if sorted(agent["new_desired_workers"]) != sorted(agent.get("desired_workers", [])):
                  connections.mongodb_jobs.mrq_agents.update_one({"_id": agent["_id"]}, {"$set": {
                      "desired_workers": agent["new_desired_workers"]
                  }})
  
          # Remember the date of the last successful orchestration (will be reported)
          self.dateorchestrated = datetime.datetime.utcnow()
  
          log.debug("Orchestration finished.")
docs: Manage the desired workers of *all* the agents in the given group