docs: @Override
    public boolean onSchedule(PackingPlan packing) {
      LOG.info("Starting to deploy topology: " + LocalContext.topologyName(config));
  
      synchronized (processToContainer) {
        LOG.info("Starting executor for TMaster");
        startExecutor(0, null);
  
        // for each container, run its own executor
        for (PackingPlan.ContainerPlan container : packing.getContainers()) {
          startExecutor(container.getId(), container.getInstances());
        }
      }
  
      LOG.info("Executor for each container have been started.");
  
      return true;
    }