git.delta.rocks / jrsonnet / refs/commits / 1e20ff1f8900

61impl BuildSystems {61impl BuildSystems {
62	pub async fn run(self, config: &Config, opts: &FleetOpts) -> Result<()> {62	pub async fn run(self, config: &Config, opts: &FleetOpts) -> Result<()> {
63		let hosts = opts.filter_skipped(config.list_hosts()?)?;63		let hosts = opts.filter_skipped(config.list_hosts()?)?;
64		let mut tasks = FuturesUnordered::new();64		let tasks = FuturesUnordered::new();
65		let build_attr = self.build_attr.clone();65		let build_attr = self.build_attr.clone();
66		for host in hosts {66		for host in hosts {
67			let config = config.clone();67			let config = config.clone();
89				.instrument(span),89				.instrument(span),
90			);90			);
91		}91		}
92		for _task in tasks.next().await {}92		tasks.collect::<Vec<()>>().await;
93		Ok(())93		Ok(())
94	}94	}
95}95}
171				.instrument(span),171				.instrument(span),
172			);172			);
173		}173		}
174		for _task in tasks.next().await {}174		tasks.collect::<Vec<()>>().await;
175		Ok(())175		Ok(())
176	}176	}
177}177}