code: def run(self, *nodes):
          
          nodes = nodes or self.nodes
          self._prelude(*nodes)
  
          @write_yaml_report
          def _run():
              self._build_installer()
              runner = functools.partial(run_on_host, self.campaign)
              if self.campaign.network.max_concurrent_runs > 1:
                  pool = Pool(self.campaign.network.max_concurrent_runs)
                  pool.map(runner, nodes)
              else:
                  for node in nodes:
                      runner(node)
              return nodes
  
          with pushd(self.campaign_path):
              _run()
docs: Execute benchmarks on every node specified in arguments.
          If none are given, then execute benchmarks on every nodes
          specified in the ``network.nodes`` campaign configuration.