From 3ec6aeb93523e7e7d8a6929f8736071f56ea1f83 Mon Sep 17 00:00:00 2001 From: Brian George Date: Wed, 18 Sep 2024 20:44:35 -0400 Subject: [PATCH] Join runer subtask --- src/command/supergraph/compose/do_compose.rs | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/src/command/supergraph/compose/do_compose.rs b/src/command/supergraph/compose/do_compose.rs index 0439a83bf..2b5bf9653 100644 --- a/src/command/supergraph/compose/do_compose.rs +++ b/src/command/supergraph/compose/do_compose.rs @@ -15,6 +15,7 @@ use semver::Version; use serde::Serialize; use std::io::Read; use tempfile::NamedTempFile; +use tokio::join; use tokio_stream::StreamExt; use rover_client::shared::GraphRef; @@ -195,12 +196,14 @@ impl Compose { let runner = crate::composition::runner::Runner::new(supergraph_config, supergraph_binary); let mut messages = runner.run().await?; - tokio::task::spawn(async move { + let join_handle = tokio::task::spawn(async move { while let Some(message) = messages.next().await { eprintln!("{:?}", message); } }); + join!(join_handle).0?; + return Ok(RoverOutput::EmptySuccess); } let mut supergraph_config = get_supergraph_config(